Struct AsyncRunner 

pub struct AsyncRunner { /* private fields */ }

Implementations

impl AsyncRunner

pub fn new() -> Self

Creates a new AsyncRunner instance.

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).

impl AsyncRunner

pub async fn run(&mut self)

Runs the async runner event loop.

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

pub fn handle_time_event(handler: TimeEventHandlerV2)

Handles a time event by running its callback.

pub fn handle_data_command(cmd: DataCommand)

Handles a data command by sending to the DataEngine.

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)

Handles an execution command by sending to the ExecEngine.

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.