Versions in this module Expand all Collapse all v0 v0.0.11 May 13, 2026 Changes in this version + const DefaultFIFOSize + const DefaultPubSubCapacity + type FIFO struct + func NewFIFO[T any](ctx context.Context, capacity int) *FIFO[T] + func (b *FIFO[T]) In() chan<- T + func (b *FIFO[T]) Out() <-chan T + func (b *FIFO[T]) Stop(ctx context.Context) + type PubSub struct + func New[T any]() *PubSub[T] + func (ps *PubSub[T]) Close() + func (ps *PubSub[T]) Publish(item T) + func (ps *PubSub[T]) Subscribe(ctx context.Context, capacity int) *Subscriber[T] + func (ps *PubSub[T]) Unsubscribe(sub *Subscriber[T]) + type Subscriber struct + func (s *Subscriber[T]) C() <-chan T
Go to main page