Struct ExecutionStream 

pub struct ExecutionStream { /* private fields */ }

Sequenced state for the executions an agent prepared in one market. The stream opens with a watch frame for the requested handles and begins with a snapshot; later watch calls add handles on the same stream. Any market or sequence mismatch fails closed so the caller reconnects.

Implementations

impl ExecutionStream

pub fn market_id(&self) -> &str

pub async fn watch(&mut self, execution_ids: &[String]) -> Result<(), SdkError>

Watch additional handles; the server answers with an update or unknown event per new handle on the same sequence.

pub async fn next_event( &mut self, ) -> Result<Option<PlatformExecutionEvent>, SdkError>

The first call returns the snapshot received during connection. Later calls return sequenced update, expired, unknown, heartbeat, or recovery snapshot events.

pub async fn close(&mut self) -> Result<(), SdkError>

Trait Implementations

impl Debug for ExecutionStream

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

Formats the value using the given formatter.