IteratorToWriter reads objects from the provided iterator and writes them to the provided writer.

NewBufferWriter returns a new BufferWriter with the given capacity.

NewBuilder returns a new builder.

NewChannelIterator returns a new ChannelIterator.

NewLimitedIterator returns a new LimitIterator that serialy iterators through the given iterators.

NewMultiIterator returns a new MultiIterator that serialy iterators through the given iterators.

NewSetIterator returns a new SetIterator.

NewSliceIterator returns a new SliceIterator.

NewSyncWriter returns a new SyncWriter.

NewTransactionWriter returns a new TransactionWriter with the opener function and optional closer function.

BufferWriter wraps a buffer around an underlying writer.

Builder helps build a pipeline.

ChannelIterator iterates over a channel of values.

ChannelWriter passes each object to the callback function.

FunctionIterator provides a simple wrapper over a callback function to allow it to iterate.

FunctionWriter passes each object to the callback function.

LimitedIterator returns an iterator that reads up to a given number of objects from the underlying reader.

MultiIterator returns an Iterator that's the logical concatenation of the provided input iterators.

MultiWriter creates a writer that duplicates its writes to all the provided writers.

SetIterator iterates over the keys in a map.

SetWriter contains the WriteObject and Flush functions for writing objects as keys to a set.

SliceIterator iterates over an array or slice of values.

SliceWriter contains the WriteObject and Flush functions for writing objects to an underlying slice.

SyncWriter wraps a mutex around an underlying writer, so writes happen sequentially.

TransactionWriter opens up a transaction to the underlying writer and closes the underlying writer after the objects are written.

BatchWriter contains the WriteObjects and Flush functions for writing a batch of objects.

Iterator contains the Next function that returns an object until it returns an io.EOF error.

Writer contains the WriteObject and Flush functions for writing objects.