Module 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
- rewind
- wrappers
- Wrappers for Tokio types that implement
Stream.
- ChainReader
- Reader that can be used to chain two readers together.
- Elapsed
- Error returned by
Timeout and TimeoutRepeating. - Empty
- Stream for the
empty function. - HeapReader
- Reader for reading from a heap-allocated bytes buffer.
- Iter
- Stream for the
iter function. - Once
- Stream for the
once function. - PeekStream
- a stream which has peeked some data of the inner stream,
to be read first prior to any other reading
- Pending
- Stream for the
pending function. - StackReader
- Reader for reading from a stack buffer
- 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 is a type that implements
AsyncRead, AsyncWrite and Send.
This is specific to Rama and is directly linked to the supertraits of Tokio. - 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