Crate plumbum [] [src]

Macros

pipe!

Provides a convient syntax for conduit operations.

Structs

Kleisli

The Kleisli arrow from A to ConduitM<I, O, B>.

Enums

ConduitM

Represents a conduit, i.e. a sequence of await/yield actions.

Functions

consume

Wait for a single input value from upstream.

produce

Send a value downstream to the next component to consume.

Type Definitions

Conduit

Consumes a stream of input values and produces a stream of output values, without producing a final result.

Sink

Consumes a stream of input values and produces a final result, without producing any output.

Source

Provides a stream of output values, without consuming any input or producing a final result.