Expand description

Helpers for manipulating built-in streams

Structs

A JoinHandle that cancels the Future when dropped, rather than detaching it

A Backoff wrapper that resets after a fixed duration has elapsed.

Applies a Backoff policy to a [Stream]

Functions

Flattens each item in the list following the rules of watcher::Event::into_iter_applied.

Flattens each item in the list following the rules of watcher::Event::into_iter_touched.