Struct TimeoutStream 

pub struct TimeoutStream<S> { /* private fields */ }

Stream wrapper that yields timeout errors after a fixed duration.

Implementations

impl<S> TimeoutStream<S>

pub fn new(inner: S, duration: Duration) -> Self

Creates a timeout stream using wall-clock time.

pub fn with_time_getter( inner: S, duration: Duration, time_getter: fn() -> Time, ) -> Self

Creates a timeout stream using a custom time source.

Trait Implementations

impl<S: SymbolStream + Unpin> SymbolStream for TimeoutStream<S>

fn poll_next( self: Pin<&mut Self>, cx: &mut Context<'_>, ) -> Poll<Option<Result<AuthenticatedSymbol, StreamError>>>

Receive the next symbol.

fn size_hint(&self) -> (usize, Option<usize>)

Hint about remaining symbols (if known).

fn is_exhausted(&self) -> bool

Check if the stream is exhausted.