GetIteratorContext allows the retrieval of the context of the iterator from within a transformer.

NewChanIterator builds a ChanIterator and starts the goroutines pumping items from the input iterators.

NewRowsIterator makes a StructIterator[T] from a ScannableIterator.

NewSliceIterator constructs a SliceIterator from a slice of items (rows).

NewSqlxIterator makes a SqlxIterator[T] producing items of type T from a github.com/jmoiron/sqlx.Rows cursor.

NewTransformIterator makes a StructIterator[T] from a ScannableIterator.

WithChanFanInBuffers allocates buffers to fan-in the input results.

WithChanPreallocatedItems preallocate n items in the returned slice when using the Collect and CollectPtr methods.

WithRowsPreallocatedItems preallocate n items in the returned slice when using the Collect and CollectPtr methods.

ChanIterator is a channel-based iterator that may be used to run a collection of StructIterators in parallel.

SliceIterator constructs an iterator based on a slice of items.