Struct ManagedClientSession 

pub struct ManagedClientSession { /* private fields */ }

Running managed client session.

ManagedClientSession::join waits for the worker and returns the session outcome or client error. Dropping the session requests cooperative cancellation; callers that need the outcome should explicitly join instead of relying on drop.

Implementations

impl ManagedClientSession

pub fn subscribe( &self, config: SubscriberConfig, ) -> Result<EventSubscription, ClientError>

Add another event subscriber to this running managed session.

The subscription receives only events published after it is registered.

pub fn stop(&self)

Request cooperative cancellation of the managed session.

Cancellation is observed by the worker loop between socket receive, timeout polling, and send scheduling steps. Call join to wait for the worker and obtain the final SessionOutcome.

pub fn join(self) -> Result<SessionOutcome, ClientError>

Wait for the managed worker thread to finish.

On success, returns lifecycle counters for the completed session. If the worker panicked, this returns ClientError::WorkerPanicked. Joining also disconnects all event subscriptions while leaving already queued events available to drain.

Trait Implementations

impl Debug for ManagedClientSession

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

Formats the value using the given formatter.

impl Drop for ManagedClientSession

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.