Module ex_futures::stream [−] [src]

Structs

Cloneable	A cloneable stream being created by `unsync_cloneable` function. You can `clone` this stream as you want. Each cloned stream is also cloneable.
FindFirst
FindFirstMap
Fork	Fork any kind of stream into two stream like that the river branches. The closure being passed this function is called "router". Each item of original stream is passed to branch following to "router" decision. "Router" can return not only `Side` which is `Left` or `Right` but also `bool` (`true` is considered as `Left`).
UnsyncCloneable	A cloneable stream being created by `unsync_cloneable` function. You can `clone` this stream as you want. Each cloned stream is also cloneable.
UnsyncFork	UnsyncFork any kind of stream into two stream like that the river branches. The closure being passed this function is called "router". Each item of original stream is passed to branch following to "router" decision. "Router" can return not only `Side` which is `Left` or `Right` but also `bool` (`true` is considered as `Left`).

An extention of Stream provided by futures crate. Any Stream implements StreamExt automatically. All you is to import StreamExt.