Chain joins multiple streams in order, fully consuming one before moving to the next.

Collect aggregates a stream into a slice.

CollectPages aggregates a paginated stream into a slice.

Drain consumes a stream to completion.

Empty creates an empty stream (equivalent to Fail(nil)).

Fail creates an empty stream that fails immediately with the supplied error.

FilterMap maps a stream of type A into a stream of type B, filtering out items when fn returns false.

Flatten flattens a stream of streams into a single stream of items.

Func builds a stream from a closure.

MapErr maps over the error returned by Done().

MapWhile maps a stream of type A into a stream of type B, halting early if fn returns false.

MergeStreams merges two streams and returns a single stream which uses the provided less function to determine which item to yield.

Once creates a stream that yields a single item.

OnceFunc builds a stream from a closure that will yield exactly zero or one items.

PageFunc is equivalent to Func except that it performs internal depagination.

RateLimit applies a rate-limiting function to a stream s.t.

Skip skips the first n items from a stream.

Slice constructs a stream from a slice.

Take takes the next n items from a stream.

Stream is a generic interface for streaming APIs.