@metreeca/pipe - v0.9.11
    Preparing search index...

    Module feeds

    Factory functions that create new pipes from various input sources.

    Custom Feeds are functions that create new pipes:

    import { items, toArray, type Pipe } from '@metreeca/pipe';

    function repeat<V>(value: V, count: number): Pipe<V> {
      return items(async function* () {
        for (let i = 0; i < count; i++) { yield value; }
      }());
    }

    await repeat(42, 3)(toArray());  // [42, 42, 42]
    Caution

    When creating custom feeds, always wrap async generators, async generator functions, or AsyncIterable<T> objects with items to ensure undefined filtering and proper pipe interface integration.

    Functions

    items

    Creates a pipe from a data source.

    range

    Creates a pipe that yields a sequence of numbers within a range.

    iterate

    Creates a pipe by repeatedly calling a generator function until exhausted.

    chain

    Chains multiple data sources into a single stream, preserving source order.

    merge

    Merges multiple data sources into a single stream, yielding items as they become available.

    Settings

    Member Visibility

    On This Page

    Functions