Struct ParallelSubSession 

pub struct ParallelSubSession { /* private fields */ }

One sub-session of a parallel run. Mirrors the driver-facing surface of super::ManagedBacktestSession: control events arrive over a demuxed channel from the shared control connection, while transactions flow over this sub-session’s own data-plane subscription managers.

Implementations

impl ParallelSubSession

pub fn session_info(&self) -> &SessionInfo

pub fn range(&self) -> (u64, u64)

Server-authoritative (start_slot, end_slot) for this sub-session.

pub fn subscribe_transactions(&mut self, program_ids: Vec<String>)

pub fn subscribe_account_diffs(&mut self, program_ids: Vec<String>)

pub async fn next_event(&mut self) -> Result<ManagedEvent, ManagedSessionError>

Receive the next control or subscription event for this sub-session. On Completed, trailing subscription notifications are drained and delivered before the Completed event, mirroring super::ManagedBacktestSession.

pub async fn send_continue( &mut self, params: ContinueParams, ) -> Result<(), ManagedSessionError>

Wait until the shared control connection and this sub-session’s subscriptions are up, then route a Continue as ContinueSessionV1.

pub async fn shutdown(self)

Cancel this sub-session’s subscriptions and join them. The shared control connection is owned by ManagedParallelSession and is not touched here.

Trait Implementations

impl Drop for ParallelSubSession

fn drop(&mut self)

Executes the destructor for this type.

fn pin_drop(self: Pin<&mut Self>)

🔬This is a nightly-only experimental API. (pin_ergonomics)

Execute the destructor for this type, but different to Drop::drop, it requires self to be pinned.