Crate streamtools

Additional stream combinators.

Feature flags

• tokio-time: Enables combinators which depend on the tokio crate and its time feature, in particular:
  • sample_by_duration
  • sample_by_interval
• test-util: Exposes utilities for testing streams, in particular:
  • delay_items
  • record_delay

Modules

• test_utiltest-util
  Utilities for testing streams

Structs

• FastForward
  Stream for the fast_forward method.
• FlattenSwitch
  Stream for the flatten_switch method.
• RecordDelaytest-util
  Stream for the record_delay method.
• Sample
  Stream for the sample method.
• ThrottleLasttokio-time
  Stream for the throttle_last method.

Traits

• StreamTools
  An extension trait for the Stream trait that provides a variety of convenient combinator functions.