Crate ruchei 

Utilities for working with many streams

Re-exports

pub use ruchei_callback as callback;unstable

pub use ruchei_extend as extend;extend

pub use ruchei_extra as with_extra;extra

pub use ruchei_itertools as itertools;itertools

Modules

compressunstable

concurrentstd

Await futures concurrently.

connection_item

dealconnection and extend

Sinks with round-robin distribution inspired by ZeroMQ’s DEALER sockets.

echo

group_sequentialunstable

livenessunstable and std

merge

multicastconnection and extend

Convert a Stream of Stream+Sinks into single Stream+Sink.

poll_on_wake

Prevent polling until the wake up.

routeconnection

use_latest

Stream+Sink from a Stream of Stream+Sinks switching to a new one as soon as it becomes available.

with_reply