Trait rabble::Process

pub trait Process<T>: Send {
    fn handle(
        &mut self, 
        msg: Msg<T>, 
        from: Pid, 
        correlation_id: Option<CorrelationId>, 
        output: &mut Vec<Envelope<T>>
    );

    fn init(&mut self, _executor_pid: Pid) -> Vec<Envelope<T>> { ... }
}

Required Methods

fn handle(
    &mut self,
    msg: Msg<T>,
    from: Pid,
    correlation_id: Option<CorrelationId>,
    output: &mut Vec<Envelope<T>>
)

Handle messages from other actors

Provided Methods

fn init(&mut self, _executor_pid: Pid) -> Vec<Envelope<T>>

Initialize process state if necessary

Implementors