Crate ruchei

Utilities for working with many streams

Re-exports

• pub use ruchei_callback as callback;
• pub use ruchei_extra as with_extra;

Modules

• close_all
• compress
• concurrent
  Await futures concurrently.
• echo
• group_by_key
  Grouping of items by key.
• multicast
  Convert a Stream of Stream+Sinks into single Stream+Sink.
• pinned_extend
• poll_on_wake
  Prevent polling until the wake up.
• read_callback
• route
  Sinks with routing inspired by ZeroMQ’s ROUTER sockets.
• rw_isolation
• switching
  Stream+Sink from a Stream of Stream+Sinks switching to a new one as soon as it becomes available.
• timeout_unused
  Close Stream on timer running out.