@metreeca/flow - v0.9.21
    Preparing search index...

    Module index

    Composable asynchronous iterable processing.

    Defines the contracts a pipe is assembled from: the Feed carrying the items, the tasks and sinks applied to it, and the Data shapes a feed can be opened from. A pipe composes a feed with any number of tasks and an optional sink, wrapped in the pipe factory. The companion feed, task and sink modules build on these contracts, and custom operations honouring them compose with the built-in ones interchangeably.

    Important

    Feeds never carry undefined: values are dropped as they enter one, whether contributed by a data source or yielded by a task, custom ones included, so no task or sink ever observes one. Other falsy values, null, 0, false and "" among them, are preserved.

    Type Aliases

    Data

    Data accepted wherever a feed is opened or extended.

    Functions

    pipe

    Creates a pipe.

    Interfaces

    Feed

    Feed under composition.

    Task

    Intermediate operation applied to a feed.

    Sink

    Terminal operation applied to a feed.