Module futures_ext::stream

Module extending functionality of [futures::stream] module

Structs

• BufferedParams
  Params for crate::FbStreamExt::buffered_weight_limited and WeightLimitedBufferedStream
• ReturnRemainder
  A stream wrapper returned by StreamExt::return_remainder
• StreamTimeoutError
  Error returned when a StreamWithTimeout exceeds its deadline.
• StreamWithTimeout
  A stream that must finish within a given duration, or it will error during poll (i.e. it must yield None). The clock starts counting the first time the stream is polled.
• WeightLimitedBufferedStream
  Like [stream::Buffered], but can also limit number of futures in a buffer by “weight”.
• WeightLimitedBufferedTryStream
  Like [stream::Buffered], but is for TryStream and can also limit number of futures in a buffer by “weight”
• YieldPeriodically
  A stream that will yield control back to the caller if it runs for more than a given duration without yielding (i.e. returning Poll::Pending). The clock starts counting the first time the stream is polled, and is reset every time the stream yields.

Traits

• FbStreamExt
  A trait implemented by default for all Streams which extends the standard functionality.
• FbTryStreamExt
  A trait implemented by default for all TryStreams which extends the standard functionality.