Module operator 

Contracts and execution context for pipeline sources and operators.

Structs

Cx

What a source or stage may touch during one call: its pipeline’s inlets, the bytes the source asked for, and the session.

Enums

Input

What an operator is handed by the stage below it.

SourceBlocked

Why a source cannot compute yet.

SourceReady

Whether a source can compute or needs the scheduler to wait.

Step

The output of one non-blocking compute call.

Traits

Operator

Computes batches without blocking, either as a source or as a stage transforming input.

Source

The start of a pipeline: produces batches from its inlets and the segments it asks to have read.