Module tokio::stream

Expand description

Stream utilities for Tokio.

A Stream is an asynchronous sequence of values. It can be thought of as an asynchronous version of the standard library’s Iterator trait.

This module provides helpers to work with them.

Structs

Stream for the empty function.

Stream for the iter function.

Stream for the once function.

Stream for the pending function.

Combine many streams into one, indexing each source stream with a unique key.

Convert from a Stream.

A stream of values produced asynchronously.

An extension trait for Streams that provides a variety of convenient combinator functions.

Creates a stream that yields nothing.

Converts an Iterator into a Stream which is always ready to yield the next value.

Creates a stream that emits an element exactly once.

Creates a stream that is never ready