Function multi_producer_sink::sync_mps [] [src]

pub fn sync_mps<S: Sink>(sink: S) -> (SyncMPS<S>, SyncDone<S>)

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.