Struct AsyncRunner 

pub struct AsyncRunner { /* private fields */ }

Implementations

impl AsyncRunner

pub fn new() -> Self

Creates a new AsyncRunner instance.

Creates channels but does not bind senders to thread-local storage. Call bind_senders before creating clients that read from TLS, and again before entering the event loop.

pub fn bind_senders(&self)

Binds this runner’s channel senders to thread-local storage.

Call before creating clients that read from TLS (e.g., in the builder), and again before entering the event loop to reclaim ownership if another runner was constructed on this thread in the interim.

pub fn stop(&self)

Stops the runner with an internal shutdown signal.

pub fn handle(&self) -> AsyncRunnerHandle

Returns a handle that can be used to stop the runner from another context.

pub fn take_channels(self) -> AsyncRunnerChannels

Consumes the runner and returns the channel receivers for direct event loop driving.

This is used when the event loop needs to run on the same thread as the msgbus endpoints (which use thread-local storage).

pub fn flush_pending_data(&mut self)

Flushes all pending data events and commands from the channels.

Loops until both data channels are empty, processing each item into the cache immediately. Used in start() where channels are not extracted.

pub async fn run(&mut self) -> Result<()>

Runs the async runner event loop.

This method processes time, system, execution, and data events in an async loop. It will run until a signal is received or the event streams are closed.

Errors

Returns a callback dispatch failure, retaining pending channel messages and the failure latch.

pub fn handle_time_event(message: DispatchMessage<TimeEventMessage>) -> bool

Handles a time event under its originating callback root.

Panics

Panics if a rooted message is processed outside its owner thread.

pub fn handle_data_command(cmd: DispatchMessage<DataCommand>)

Handles a data command under its captured callback root by sending to the DataEngine.

Panics

Panics if a rooted command is processed outside its owner thread.

pub fn dispatch_data_event(event: DispatchMessage<DataEvent>)

Dispatches a received data event under its originating callback root.

Panics

Panics if a rooted message is processed outside its owner thread.

pub fn dispatch_exec_event(event: DispatchMessage<ExecutionEvent>)

Dispatches a received execution event under its originating callback root.

Panics

Panics if a rooted message is processed outside its owner thread.

pub fn handle_data_event(event: DataEvent)

Handles a data event by sending to the appropriate DataEngine endpoint.

pub fn handle_exec_command(cmd: TradingCommand)

Dispatches an internal execution command directly to the execution engine.

pub fn handle_trading_command(message: DispatchMessage<TradingCommandMessage>)

Dispatches a trading command and its deferred children under their captured callback roots.

Panics

Panics if a rooted command is processed outside its owner thread.

pub fn handle_exec_event(event: ExecutionEvent)

Handles an execution event by sending to the appropriate engine endpoint.

pub fn handle_exec_report(report: ExecutionReport)

Trait Implementations

impl Debug for AsyncRunner

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for AsyncRunner

fn default() -> Self

Returns the “default value” for a type.