Crate callbag[][src]

Macros

Callbag factory that merges data from multiple callbag sources.

Utility function for plugging callbags together in chain.

Structs

A Callbag dynamically receives input of type I and dynamically delivers output of type O.

Enums

A message passed to a Callbag.

Functions

Callbag operator that conditionally lets data pass through.

Callbag operator that flattens a higher-order callbag source.

Callbag sink that consumes both pullable and listenable sources.

Converts an iterator to a callbag pullable source.

Callbag operator that applies a transformation on data passing through it.

Callbag factory that merges data from multiple callbag sources.

Callbag operator that combines consecutive values from the same source.

Callbag operator that skips the first N data points of a source.

Callbag operator that limits the amount of data sent by a source.

Type Definitions

A sink only receives data.

A source only delivers data.