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.

NewCond returns a new Cond and starts the controller loop.

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

Atomic is a type-safe wrapper around atomic.Value.

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

Cond implements a channel-based synchronization for goroutines that wait for signals or send them.

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.

The WaiterFunc type is an adapter to allow the use of ordinary functions as Waiter.