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

Stream extension to simplify building TimeoutStream

Required Methods

Create new TimeoutStream

Implementors