Trait mogwai::sink::Sink

pub trait Sink<Item> {
    // Required methods
    fn send(
        &self,
        item: Item
    ) -> Pin<Box<dyn Future<Output = Result<(), SendError>> + Send + '_>>;
    fn try_send(&self, item: Item) -> Result<(), TrySendError>;
}

Required Methods

fn send( &self, item: Item ) -> Pin<Box<dyn Future<Output = Result<(), SendError>> + Send + '_>>

fn try_send(&self, item: Item) -> Result<(), TrySendError>

Implementations on Foreign Types

impl<S: ?Sized + Sink<Item>, Item> Sink<Item> for Box<S>

fn send( &self, item: Item ) -> Pin<Box<dyn Future<Output = Result<(), SendError>> + Send + '_>>

fn try_send(&self, item: Item) -> Result<(), TrySendError>

Implementors

impl<Item: Clone + Send + Sync> Sink<Item> for mogwai::channel::broadcast::Sender<Item>

impl<Item: Send + Sync> Sink<Item> for mogwai::channel::mpsc::Sender<Item>

impl<S, X, Y, F> Sink<X> for ContraFilterMap<S, X, Y, F>where S: Sink<Y> + Unpin, F: Fn(X) -> Option<Y> + Unpin, X: Unpin, Y: Unpin,

impl<S, X, Y, F> Sink<X> for ContraMap<S, X, Y, F>where S: Sink<Y> + Unpin, F: Fn(X) -> Y + Unpin, X: Unpin, Y: Unpin,

impl<T: Clone + Send + Sync> Sink<T> for FanInput<T>

impl<T: Clone + Send + Sync> Sink<T> for Output<T>

impl<T: Send + Sync + Clone> Sink<T> for Captured<T>

impl<T: Send> Sink<T> for Input<T>