Skip to main contentModule stream
- adapters
- Adapters for
Streams created by methods in StreamExt. - codec
- Adaptors from
AsyncRead/AsyncWrite to Stream/Sink - io
- Helpers for IO related tasks.
- json
- ndjson support in rama
- wrappers
- Wrappers for Tokio types that implement
Stream.
- Elapsed
- Error returned by
Timeout and TimeoutRepeating. - Empty
- Stream for the
empty function. - Iter
- Stream for the
iter function. - Once
- Stream for the
once function. - Pending
- Stream for the
pending function. - StreamMap
- Combine many streams into one, indexing each source stream with a unique
key.
- StreamNotifyClose
- A
Stream that wraps the values in an Option. - Timeout
- Stream returned by the
timeout method.
- FromStream
- Convert from a
Stream. - Stream
- A stream of values produced asynchronously.
- StreamExt
- An extension trait for the
Stream trait that provides a variety of
convenient combinator functions.
- empty
- Creates a stream that yields nothing.
- iter
- Converts an
Iterator into a Stream which is always ready
to yield the next value. - once
- Creates a stream that emits an element exactly once.
- pending
- Creates a stream that is never ready