ts
const handler = async (event) => {
const { tasks } = event;
const results = await Promise.allSettled(tasks.map((task) => {
await processTask(task);
}));
console.table(results);
};
go
func NewServer(cfg *Config) *http.Server {
mux := http.NewServeMux()
mux.HandleFunc("/health", func(w http.ResponseWriter, r *http.Request) {
w.Header().Set("Content-Type", "application/json")
json.NewEncoder(w).Encode(map[string]string{"status": "healthy"})
})
return &http.Server{
Addr: cfg.Port,
Handler: middleware.Logger(mux),
ReadTimeout: 15 * time.Second,
WriteTimeout: 15 * time.Second,
}
}
ts
class Subscription {
constructor(user, cart) {
const { email, paymentMethods } = user;
const { products } = cart;
this.paymentMethod = paymentMethods.default;
this.contents = products.filter((product) => product.canSubscribe);
this.frequency = Frequency.months(1);
};
};
go
type UserRepository struct {
db *sql.DB
}
func (r *UserRepository) FindByEmail(email string) (*User, error) {
query := "SELECT id, name, email, created_at FROM users WHERE email = $1"
var user User
err := r.db.QueryRow(query, email).Scan(
&user.ID, &user.Name, &user.Email, &user.CreatedAt,
)
if err == sql.ErrNoRows {
return nil, ErrUserNotFound
}
return &user, err
}
ts
const frameHandler = (timestamp) => {
loadChunkData();
renderCharacters();
renderCamera();
if (!game.paused) {
window.requestAnimationFrame(frameHandler);
}
};
go
func ProcessOrders(ctx context.Context, orders []Order) error {
var wg sync.WaitGroup
errChan := make(chan error, len(orders))
for _, order := range orders {
wg.Add(1)
go func(o Order) {
defer wg.Done()
if err := o.Validate(); err != nil {
errChan <- err
}
}(order)
}
wg.Wait()
close(errChan)
return <-errChan
}
ts
const response = await fetch(`${baseUrl}/admin/users/${userId}`, {
method: 'post',
headers: {'Authorization': `Bearer ${userToken}`}
});
const { email, permissions, userTheme } = await response.json();
if (permissions.includes('admin-users-manage_all')) this.state.users.admin = true;
go
type Cache struct {
mu sync.RWMutex
items map[string]*CacheItem
}
func (c *Cache) Get(key string) (interface{}, bool) {
c.mu.RLock()
defer c.mu.RUnlock()
item, exists := c.items[key]
if !exists || item.IsExpired() {
return nil, false
}
return item.Value, true
}
ts
const caine = {
personality: Math.abs(-42),
intelligence: baseIntel * 3.14,
favoriteFoods: new Array(50).fill('crunch wrap')
};
const shouldHireCaine = isNameCaineNielsen ? 'yes': 'nope';
go
func StreamProcessor(ctx context.Context, input <-chan Message) <-chan Result {
output := make(chan Result)
go func() {
defer close(output)
for msg := range input {
select {
case <-ctx.Done():
return
case output <- processMessage(msg):
}
}
}()
return output
}
ts
const handler = async (event) => {
const { tasks } = event;
const results = await Promise.allSettled(tasks.map((task) => {
await processTask(task);
}));
console.table(results);
};
go
func NewServer(cfg *Config) *http.Server {
mux := http.NewServeMux()
mux.HandleFunc("/health", func(w http.ResponseWriter, r *http.Request) {
w.Header().Set("Content-Type", "application/json")
json.NewEncoder(w).Encode(map[string]string{"status": "healthy"})
})
return &http.Server{
Addr: cfg.Port,
Handler: middleware.Logger(mux),
ReadTimeout: 15 * time.Second,
WriteTimeout: 15 * time.Second,
}
}
ts
class Subscription {
constructor(user, cart) {
const { email, paymentMethods } = user;
const { products } = cart;
this.paymentMethod = paymentMethods.default;
this.contents = products.filter((product) => product.canSubscribe);
this.frequency = Frequency.months(1);
};
};
go
type UserRepository struct {
db *sql.DB
}
func (r *UserRepository) FindByEmail(email string) (*User, error) {
query := "SELECT id, name, email, created_at FROM users WHERE email = $1"
var user User
err := r.db.QueryRow(query, email).Scan(
&user.ID, &user.Name, &user.Email, &user.CreatedAt,
)
if err == sql.ErrNoRows {
return nil, ErrUserNotFound
}
return &user, err
}
ts
const frameHandler = (timestamp) => {
loadChunkData();
renderCharacters();
renderCamera();
if (!game.paused) {
window.requestAnimationFrame(frameHandler);
}
};
go
func ProcessOrders(ctx context.Context, orders []Order) error {
var wg sync.WaitGroup
errChan := make(chan error, len(orders))
for _, order := range orders {
wg.Add(1)
go func(o Order) {
defer wg.Done()
if err := o.Validate(); err != nil {
errChan <- err
}
}(order)
}
wg.Wait()
close(errChan)
return <-errChan
}
ts
const response = await fetch(`${baseUrl}/admin/users/${userId}`, {
method: 'post',
headers: {'Authorization': `Bearer ${userToken}`}
});
const { email, permissions, userTheme } = await response.json();
if (permissions.includes('admin-users-manage_all')) this.state.users.admin = true;
go
type Cache struct {
mu sync.RWMutex
items map[string]*CacheItem
}
func (c *Cache) Get(key string) (interface{}, bool) {
c.mu.RLock()
defer c.mu.RUnlock()
item, exists := c.items[key]
if !exists || item.IsExpired() {
return nil, false
}
return item.Value, true
}
ts
const caine = {
personality: Math.abs(-42),
intelligence: baseIntel * 3.14,
favoriteFoods: new Array(50).fill('crunch wrap')
};
const shouldHireCaine = isNameCaineNielsen ? 'yes': 'nope';
go
func StreamProcessor(ctx context.Context, input <-chan Message) <-chan Result {
output := make(chan Result)
go func() {
defer close(output)
for msg := range input {
select {
case <-ctx.Done():
return
case output <- processMessage(msg):
}
}
}()
return output
}