Trait acto_rs::elem::gather::Gather

pub trait Gather {
    type InputValue: Send;
    type InputError: Send;
    type OutputValue: Send;
    type OutputError: Send;
    fn process(
        &mut self, 
        input: &mut Vec<ChannelWrapper<Self::InputValue, Self::InputError>>, 
        output: &mut 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 Vec<ChannelWrapper<Self::InputValue, Self::InputError>>,
    output: &mut Sender<Message<Self::OutputValue, Self::OutputError>>,
    stop: &mut bool
)

Implementors