Struct aeron_rs::concurrent::agent_invoker::AgentInvoker

pub struct AgentInvoker<T: Agent> { /* fields omitted */ }

Methods

impl<T: Agent> AgentInvoker<T>

pub fn new(agent: Arc<Mutex<T>>, exception_handler: ErrorHandler) -> Self

pub fn is_started(&self) -> bool

Has the Agent been started?

@return has the Agent been started?

pub fn is_running(&self) -> bool

Is the Agent running?

@return is the Agent been started successfully and not closed?

pub fn is_closed(&self) -> bool

Has the Agent been closed?

@return has the Agent been closed?

pub fn start(&mut self)

Mark the invoker as started and call the Agent::onStart() method.

Startup logic will only be performed once.

pub fn invoke(&self) -> i32

Invoke the Agent::doWork() method and return the work count.

If not successfully started or after closed then this method will return without invoking the {@link Agent}.

@return the work count for the Agent::doWork() method.

pub fn close(&mut self)

Mark the invoker as closed and call the Agent::onClose() logic for clean up.

The clean up logic will only be performed once.