join

Dec 26, 2023

Changes in this version

+ var ErrInputEmpty = errors.New("input channel was not specified")

+ var ErrJoinSizeZero = errors.New("join size is zero")

+ var ErrTimeoutInaccuracyTooBig = errors.New("timeout inaccuracy is too big")

+ var ErrTimeoutInaccuracyZero = errors.New("timeout inaccuracy is zero")

+ var ErrTimeoutTooSmall = errors.New("timeout value is too small")

+ type Discipline struct

+ func New[Type any](opts Opts[Type]) (*Discipline[Type], error)

+ func (dsc *Discipline[Type]) Output() <-chan []Type

+ func (dsc *Discipline[Type]) Release()

+ type Opts struct

+ Input <-chan Type

+ JoinSize uint

+ NoCopy bool

+ Timeout time.Duration

+ TimeoutInaccuracy uint