Function multi_producer_sink::unsync_mps [] [src]

pub fn unsync_mps<S: Sink>(sink: S) -> (UnsyncMPS<S>, UnsyncDone<S>)

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.