Trait aeron_rs::concurrent::agent_runner::Agent

pub trait Agent {
    fn on_start(&mut self) -> Result<(), AeronError>;
    fn do_work(&mut self) -> Result<i32, AeronError>;
    fn on_close(&mut self) -> Result<(), AeronError>;
}

The trait to be implemented by agents run within AgentRunner

Required methods

fn on_start(&mut self) -> Result<(), AeronError>

fn do_work(&mut self) -> Result<i32, AeronError>

fn on_close(&mut self) -> Result<(), AeronError>

Loading content...

Implementors

impl Agent for ClientConductor

fn on_start(&mut self) -> Result<(), AeronError>

fn do_work(&mut self) -> Result<i32, AeronError>

fn on_close(&mut self) -> Result<(), AeronError>

Loading content...