Trait tamar::Sink

pub trait Sink<V> {
    // Required method
    fn run<'a>(self, receiver: Receiver<V>) -> BoxFuture<'a, ()>;
}

Required Methods

fn run<'a>(self, receiver: Receiver<V>) -> BoxFuture<'a, ()>

Implementors

impl<V> Sink<V> for StdoutSinkwhere V: Debug + Send + 'static,