Pipeline

Inserts a bounded buffer of n elements between upstream production and downstream consumption. This is a materialization/asynchronous boundary: it preserves elements and order while decoupling producer and consumer. Closing or cancelling downstream closes the buffer and upstream.

Groups consecutive elements into non-empty Chunks of at most n elements. Full chunks have size n; on normal exhaustion the final chunk may be smaller. Grouping spans upstream read boundaries, preserves order, and uses fresh accumulation state for each materialization.

Applies pf once per input via applyOrElse, emitting only defined results while preserving order. Exceptions thrown while testing or applying pf are defects, not typed stream errors. Runtime type evidence selects specialized primitive reader paths.

Asynchronously evaluates each element, sequentially and in input order, emitting the value of Some and dropping None. A failed or defective Async becomes a stream defect, and cancellation of a suspended callback is propagated. Runtime type evidence selects specialized reader paths.

Skips the first n elements of each run, then emits the rest unchanged. Non-positive values skip nothing. Counting state is fresh for every stream or sink materialization.

Emits elements satisfying pred, in input order. The predicate is evaluated once per element; thrown exceptions are defects rather than typed stream errors. Runtime type evidence preserves primitive specialization.

Asynchronously tests each element, sequentially and in input order, emitting it only when f yields true. A failed or defective Async becomes a stream defect, and cancellation of a suspended predicate is propagated. Runtime type evidence preserves primitive specialization.

Passes every element through unchanged, preserving order, errors, and resource behavior. It is the identity for Pipeline.andThen and returns its input stream or sink unchanged, preserving any specialized reader path.

Maps each element lazily with a function whose result is Nothing. This overload preserves bottom-type inference and uses a boxed output lane. Thrown exceptions are defects rather than typed stream errors.

Lazily transforms each element with f, preserving input order and cardinality. Thrown exceptions are defects rather than typed stream errors. Runtime type evidence selects specialized primitive input and output reader paths.

Asynchronously transforms each element, sequentially and in input order. Each callback is awaited before the next element is processed. A failed or defective Async fails the stream as a defect rather than through its typed error channel; cancellation of a suspended callback is propagated. Runtime type evidence selects specialized primitive reader paths.

Emits at most the first n elements of each run and then closes upstream early. Non-positive values produce an empty stream. Counting state is fresh for every stream or sink materialization.