pub trait TimeoutTrait: Stream + GetRemote + Sized {
    fn timeout(self, duration: Duration) -> Result<TimeoutStream<Self>>;
}
Expand description

futures::Stream extension to simplify building TimeoutStream

Required Methods§

Create new TimeoutStream

Implementors§