Skip to main content

SequencerExt

Trait SequencerExt 

Source
pub trait SequencerExt: Stream {
    // Provided method
    fn sequencer(self, timeout: Duration, capacity: usize) -> Sequencer<Self>
       where Self::Item: Ord + PartialOrd<FrameId>,
             Self: Sized { ... }
}
Expand description

Stream extensions methods for item sequencing.

Provided Methods§

Source

fn sequencer(self, timeout: Duration, capacity: usize) -> Sequencer<Self>
where Self::Item: Ord + PartialOrd<FrameId>, Self: Sized,

Attaches a Sequencer to the underlying stream, given the item timeout and capacity of items.

Implementors§

Source§

impl<T> SequencerExt for T
where T: Stream + ?Sized,