pub enum ClientAgent {
Process(Message),
Collect(Instant),
Start(TransactionId, Instant),
Stop(TransactionId),
Close,
}Expand description
ClientAgent is Agent implementation that is used by Client to process transactions.
Variants§
Process(Message)
Hand an inbound message to the agent for matching against a transaction.
Collect(Instant)
Advance time so the agent can expire transactions.
Start(TransactionId, Instant)
Register a new transaction with its deadline.
Stop(TransactionId)
Abandon a transaction without waiting for its deadline.
Close
Close the agent, abandoning every outstanding transaction.
Trait Implementations§
Auto Trait Implementations§
impl Freeze for ClientAgent
impl RefUnwindSafe for ClientAgent
impl Send for ClientAgent
impl Sync for ClientAgent
impl Unpin for ClientAgent
impl UnsafeUnpin for ClientAgent
impl UnwindSafe for ClientAgent
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more