Struct Agent 

pub struct Agent { /* private fields */ }

Agent is low-level abstraction over transaction list that handles concurrency and time outs (via Collect call).

Implementations

impl Agent

pub fn new() -> Self

new initializes and returns new Agent with provided handler.

pub fn handle_event(&mut self, client_agent: ClientAgent) -> Result<()>

Applies an agent command: start, stop, process a message, collect timeouts, or close.

Errors

Fails if the agent is closed, or a transaction id is already in use.

pub fn poll_timeout(&mut self) -> Option<Instant>

When the agent next needs ClientAgent::Collect, or None with nothing outstanding.

pub fn poll_event(&mut self) -> Option<Event>

The next transaction event, or None when there is nothing to report.

Trait Implementations

impl Default for Agent

fn default() -> Agent

Returns the “default value” for a type.