Variable: graph

const graph: object

Defined in: packages/core/src/graph/stream.ts:218

Type Declaration

from()

from<TInput, TOutput>(build): Processable<TInput, TOutput>

graph.from<TInput>(build) is the root entry point for the fluent API.

The build callback receives a typed source stream and must return the sink stream. Input type is fixed by the explicit <TInput>; output type is inferred from the returned stream. Plans the DAG eagerly — cycles become construction-time PlanErrors rather than runtime failures.

The returned Processable is a drop-in replacement anywhere a Processable is expected — compose it with pipeline(), nest it inside another graph, subscribe to it, pass hooks at process time.

Type Parameters

TInput

TInput

TOutput

TOutput

Parameters

build

(src) => Stream<TOutput>

Returns

Processable<TInput, TOutput>