Crate atm_async_utils [] [src]

Utilities for working with futures::Sink and futures::Stream.

Modules

sink_futures

Futures for working with Sinks.

test_channel

An in-memory channel, primarily for testing purposes. Like futures::unsync::mpsc, but: - single-producer - allocates a vector of the full capacity in new - sender can trigger an error on the receiver - allow an arbitrary SinkError type, for use with TestSink

test_sink

Provides a wrapper for sinks, to test blocking and errors.

test_stream

Provides a wrapper for streams, to test blocking and errors.