Trait acto_rs::elem::sink::Sink

pub trait Sink {
    type InputValue: Send;
    type InputError: Send;
    fn process(
        &mut self, 
        input: &mut ChannelWrapper<Self::InputValue, Self::InputError>, 
        stop: &mut bool
    );
}

Associated Types

type InputValue: Send

type InputError: Send

Required Methods

fn process(
    &mut self,
    input: &mut ChannelWrapper<Self::InputValue, Self::InputError>,
    stop: &mut bool
)

Implementors