Module sink

Source
Expand description

Asynchronous sinks.

This module contains:

  • The Sink trait, which allows you to asynchronously write data.
  • The SinkExt trait, which provides adapters for chaining and composing sinks.

Modulesยง

buffer ๐Ÿ”’
close ๐Ÿ”’
drain ๐Ÿ”’
err_into ๐Ÿ”’
fanout ๐Ÿ”’
feed ๐Ÿ”’
flush ๐Ÿ”’
map_err ๐Ÿ”’
send ๐Ÿ”’
send_all ๐Ÿ”’
unfold ๐Ÿ”’
with ๐Ÿ”’
with_flat_map ๐Ÿ”’

Structsยง

Buffer
Sink for the buffer method.
Close
Future for the close method.
Drain
Sink for the drain function.
Fanout
Sink that clones incoming items and forwards them to two sinks at the same time.
Feed
Future for the feed method.
Flush
Future for the flush method.
Send
Future for the send method.
SendAll
Future for the send_all method.
SinkErrInto
Sink for the sink_err_into method.
SinkMapErr
Sink for the sink_map_err method.
Unfold
Sink for the unfold function.
With
Sink for the with method.
WithFlatMap
Sink for the with_flat_map method.

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ยง

assert_sink ๐Ÿ”’
drain
Create a sink that will just discard all items given to it.
unfold
Create a sink from a function which processes one item at a time.