Trait acto_rs::elem::scatter::Scatter

pub trait Scatter {
    type InputValue: Send;
    type InputError: Send;
    type OutputValue: Send;
    type OutputError: Send;
    fn process(
        &mut self, 
        input: &mut ChannelWrapper<Self::InputValue, Self::InputError>, 
        output: &mut Vec<Sender<Message<Self::OutputValue, Self::OutputError>>>, 
        stop: &mut bool
    );
}

Associated Types

type InputValue: Send

type InputError: Send

type OutputValue: Send

type OutputError: Send

Required Methods

fn process(
    &mut self,
    input: &mut ChannelWrapper<Self::InputValue, Self::InputError>,
    output: &mut Vec<Sender<Message<Self::OutputValue, Self::OutputError>>>,
    stop: &mut bool
)

Implementors