goroutines

package workpool

import (
	"context"
	"sync"
)

package pipeline

import "context"

func generate(ctx context.Context, nums ...int) <-chan int {
	out := make(chan int)

package worker

import "context"

func (p *Pool) Submit(job Job) error {
	// Reject fast if draining, otherwise enqueue with backpressure.

package scheduler

import (
	"context"
	"log"
	"sync"

package sse

type Broker struct {
	subscribers map[chan []byte]struct{}
	subscribe   chan chan []byte
	unsubscribe chan chan []byte

package limiter

import (
	"context"
	"errors"
)

package watch

import (
	"sync"
	"time"
)

package main

import (
	"context"
	"log"
	"net/http"

package pricecache

import (
	"context"
	"sync"

package apiclient

import (
	"context"
	"fmt"
	"io"

package fetch

import (
	"context"
	"net/http"

package hub

type Hub struct {
	subscribers map[*Subscriber]struct{}
	broadcast   chan []byte
	register    chan registration