Trait mz_ore::future::OreSinkExt

pub trait OreSinkExt<T>: Sink<T> {
    // Provided methods
    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>  { ... }
}

Available on crate feature async only.

Extension methods for sinks.

Provided Methods

fn boxed(self) -> Box<dyn Sink<T, Error = Self::Error> + Send>

where Self: Sized + Send + 'static,

Boxes this sink.

fn enqueue(&mut self, item: T) -> Enqueue<'_, Self, T>

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

Object Safety

This trait is not object safe.

Implementors

impl<S, T> OreSinkExt<T> for S

where S: Sink<T>,