Bulk reads all values from a channel and streams them in chunks into a returned channel.

CopyFirst asynchronously forwards all items from input to forward and synchronously returns the first item.

ErrgroupReceive adds a goroutine to the specified group that returns the first non-nil error (if any) from the specified channel.

NeverSplit returns a pseudo state machine which never demands splitting.

NewBulker returns a new Bulker and starts streaming.

WaitAsync calls Wait() on the passed Waiter in a new goroutine and sends the first non-nil error (if any) to the returned channel.

Bulker reads all values from a channel and streams them in chunks into a Bulk channel.

Counter implements an atomic counter.

Waiter implements the Wait method, which blocks until execution is complete.

BulkChunkSplitPolicy is a state machine which tracks the items of a chunk a bulker assembles.