Crate plumbum [] [src]

Modules

io

Interfacing with std::io.

Macros

fuse!

Provides a convient syntax for fusing conduits.

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.

Flush

Provide for a stream of data that can be flushed.

Functions

consume

Wait for a single input value from upstream.

defer

Defers a conduit action. Can be used to introduce artifical laziness.

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.