Versions in this module Expand all Collapse all v0 v0.55.2 Apr 12, 2025 v0.55.1 Apr 12, 2025 Changes in this version + type ChanContext struct + Ch chan T + Ctx context.Context + func NewChanContext[T any](ctx context.Context, buffer int) ChanContext[T] + func (cc ChanContext[T]) Close() + func (cc ChanContext[T]) Recv() (v T, ok bool) + func (cc ChanContext[T]) Send(v T) bool + func (cc ChanContext[T]) SendNonBlocking(v T) bool + type FanIn struct + func NewFanIn[T any](output chan T) *FanIn[T] + func (fi *FanIn[T]) AutoClose() + func (fi *FanIn[T]) Close() + func (fi *FanIn[T]) Input(chs ...<-chan T) + func (fi *FanIn[T]) Wait() + type FanOut struct + func NewFanOut[T any](input <-chan T) *FanOut[T] + func (fo *FanOut[T]) Close(ch <-chan T) + func (fo *FanOut[T]) Output() <-chan T + func (fo *FanOut[T]) OutputContext(ctx context.Context) <-chan T
Go to main page