Expand description
Asynchronous sinks
This module contains the Sink trait, along with a number of adapter types
for it. An overview is available in the documentation for the trait itself.
You can find more information/tutorials about streams online at https://tokio.rs
Structs
Sink for the Sink::buffer combinator, which buffers up to some fixed
number of values when the underlying sink is unable to accept them.
Sink that clones incoming items and forwards them to two sinks at the same time.
Future for the Sink::flush combinator, which polls the sink until all data
has been flushed.
Future for the Sink::send combinator, which sends a value to a sink and
then waits until the sink has fully flushed.
Future for the Sink::send_all combinator, which sends a stream of values
to a sink and then waits until the sink has fully flushed those values.
A sink combinator to change the error type of a sink.
Sink for the Sink::sink_map_err combinator.
A sink combinator which converts an asynchronous sink to a blocking sink.
Sink for the Sink::with combinator, chaining a computation to run prior
to pushing a value into the underlying sink.
Sink for the Sink::with_flat_map combinator, chaining a computation that returns an iterator
to run prior to pushing a value into the underlying sink
Traits
A Sink is a value into which other values can be sent, asynchronously.
Type Definitions
A type alias for Box<Sink + Send>