Interface Pipe<V>

Fluent interface for composing async stream operations.

Supports three call patterns:

Apply a task: returns a new Pipe for continued chaining
Apply a sink: returns a Promise with the final result
Get iterator: returns the underlying AsyncIterable

Type Parameters

V
The type of values in the stream

Pipe(): AsyncIterable<V>
Retrieves the underlying async iterable.

Returns AsyncIterable<V>
The async iterable for manual iteration
- Defined in index.ts:105
Pipe<R>(task: Task<V, R>): Pipe<R>
Applies a transformation task to the stream.
Type Parameters
- R
  The type of transformed values
Parameters
- task: Task<V, R>
  The task to apply
Returns Pipe<R>
A new pipe with transformed values
- Defined in index.ts:115
Pipe<R>(sink: Sink<V, R>): Promise<R>
Applies a terminal sink operation to consume the stream.
Type Parameters
- R
  The type of result
Parameters
- sink: Sink<V, R>
  The sink to apply
Returns Promise<R>
A promise resolving to the sink's result
- Defined in index.ts:125