Versions in this module Expand all Collapse all v0 v0.3.0 Jan 2, 2023 Changes in this version + type Forker struct + func Fork(joiners ...*Joiner[T]) Forker[T] + func (f *Forker[OUT]) Close() + func (f *Forker[OUT]) Sender() chan OUT + type Joiner struct + func NewJoiner(bufferLength int) Joiner[IN] + func (j *Joiner[IN]) AcquireSender() chan IN + func (j *Joiner[IN]) Receiver() chan IN + func (j *Joiner[IN]) ReleaseSender() + type Releaser func()
Go to main page