Crate multi_producer_sink [] [src]

Provides a multi-producer-sink, that allows multiple, independent handles to write to the same underlying sink.

Structs

SyncDone

A future that signals when the wrapped sink is done.

SyncMPS

A multi producer sink (SyncMPS). This is a cloneable handle to a single sink of type S, and each handle can be used to write to the inner sink.

UnsyncDone

A future that signals when the wrapped sink is done.

UnsyncMPS

A multi producer sink (UnsyncMPS). This is a cloneable handle to a single sink of type S, and each handle can be used to write to the inner sink.

Traits

MPS

A multi producer sink (MPS). This is a cloneable handle to a single sink of type S, and each handle can be used to write to the inner sink.

Functions

sync_mps

Create a new SyncMPS, wrapping the given sink. Also returns a future that emits the wrapped sink once the last SyncMPS handle has been closed, dropped or if the wrapped sink errored.

unsync_mps

Create a new UnsyncMPS, wrapping the given sink. Also returns a future that emits the wrapped sink once the last UnsyncMPS handle has been closed, dropped or if the wrapped sink errored.