Module vec 

Extension methods and implementations for streams of vector containers.

These methods operate on containers that are vectors of individual items, and much of their behavior can be described item-by-item.

Vector containers are a natural entry point before one forms a stronger opinion on the containers one would like to use. While they are easy to use, vector containers (and owned data) invite performance antipatterns around resource management (allocation and deallocation, across threads).

Re-exports

pub use self::input::Input;

pub use self::unordered_input::UnorderedInput;

pub use self::partition::Partition;

pub use self::map::Map;

pub use self::filter::Filter;

pub use self::delay::Delay;

pub use self::broadcast::Broadcast;

pub use self::branch::Branch;

pub use self::branch::BranchWhen;

pub use self::result::ResultStream;

pub use self::to_stream::ToStream;

Modules

aggregation

Aggregation operators of various flavors

branch

Operators that separate one stream into two streams based on some condition

broadcast

Broadcast records to all workers.

count

Counts the number of records at each time.

delay

Operators acting on timestamps to logically delay records

filter

Filters a stream by a predicate.

flow_controlled

Methods to construct flow-controlled sources.

input

Create new Streams connected to external inputs.

map

Extension methods for StreamVec based on record-by-record transformation.

partition

Partition a stream of records into multiple streams.

result

Extension methods for StreamVec containing Results.

to_stream

Conversion to the StreamVec type from iterators.

unordered_input

Create new Streams connected to external inputs.