Struct ControlHandle 

pub struct ControlHandle {
    pub events: Receiver<ControlEvent>,
    pub status: Receiver<ConnectionStatus>,
    /* private fields */
}

Handle to a running ControlManager task.

Fields

events: Receiver<ControlEvent>

status: Receiver<ConnectionStatus>

Implementations

impl ControlHandle

pub async fn wait_for_session(&mut self) -> Result<SessionInfo, String>

Resolve once the session has been created (or the manager has failed before reaching that point). Consumes the one-shot; callable only once.

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

Send a Continue request to the control task. Errors if the manager has exited.

pub async fn send_continue_to( &self, params: ContinueToParams, ) -> Result<(), SendError<ContinueToParams>>

Send a ContinueTo request to step to a specific slot/batch boundary. Pair with ControlEvent::DiscoveryBatch to pause before each discovered batch.

pub async fn join(self)

Await the control task’s exit. The task exits on its own when the server reports Completed, the cancel token fires, or it hits a terminal error; dropping the request channels here nudges it in the case where the driver is giving up without having seen Completed.