Module sink

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.