heim-common 0.0.11

Common stuff shared across heim project crates
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24

//! `futures::Stream` extensions

use crate::prelude::Stream;

mod choose_chain;

pub use self::choose_chain::ChooseChain;

/// heim-specific extensions for `futures::Stream`.
pub trait HeimStreamExt: Stream {
    /// Yields items from the `Self`, and if `Self` yield nothing,
    /// yields from `other` then.
    ///
    /// If `Self` yielded at least one item, `other` will not be polled at all.
    fn choose_chain<St>(self, other: St) -> ChooseChain<Self, St>
    where
        St: Stream<Item = Self::Item>,
        Self: Sized,
    {
        ChooseChain::new(self, other)
    }
}

impl<T> HeimStreamExt for T where T: Stream {}