Module futures::sink[][src]

Asynchronous sinks.

This module contains:

Structs

Buffer

Sink for the Sink::buffer combinator, which buffers up to some fixed number of values when the underlying sink is unable to accept them.

Close

Future for the close combinator, which polls the sink until all data has been closed.

Drain

A sink that will discard all items given to it.

Fanout

Sink that clones incoming items and forwards them to two sinks at the same time.

Flush

Future for the flush combinator, which polls the sink until all data has been flushed.

Send

Future for the Sink::send combinator, which sends a value to a sink and then waits until the sink has fully flushed.

SendAll

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.

SinkErrInto

A sink combinator to change the error type of a sink.

SinkMapErr

Sink for the Sink::sink_map_err combinator.

With

Sink for the Sink::with combinator, chaining a computation to run prior to pushing a value into the underlying sink.

Enums

DrainError

The error type for the Drain sink.

Traits

Sink

A Sink is a value into which other values can be sent, asynchronously.

SinkExt

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

Functions

drain

Create a sink that will just discard all items given to it.