Trait mz_ore::future::OreSinkExt

source · [−]
pub trait OreSinkExt<T>: Sink<T> {
    fn boxed(self) -> Box<dyn Sink<T, Error = Self::Error> + Send>
    where
        Self: Sized + Send + 'static,
    { ... }
    fn enqueue(&mut self, item: T) -> Enqueue<'_, Self, T>ⓘNotable traits for Enqueue<'_, Si, Item>impl<Si, Item> Future for Enqueue<'_, Si, Item> where
    Si: Sink<Item> + Unpin + ?Sized,
    Item: Unpin,     type Output = Result<(), Si::Error>; { ... }
}
Available on crate feature network only.
Expand description

Extension methods for sinks.

Provided Methods

Boxes this sink.

Like futures::sink::SinkExt::send, but does not flush the sink after enqueuing item.

Implementors