Struct TapSessionHandle 

pub struct TapSessionHandle {
    pub rx: Receiver<TapPayload>,
    pub captured: Arc<AtomicU64>,
    pub dropped: Arc<AtomicU64>,
    /* private fields */
}

Handle returned to the streaming task on a successful TapRegistry::register. Owns the receiving end of the session channel and deregisters the session from the registry on drop, so a dropped client connection tears the session down automatically and stops the hot path from offering to a dead session.

Fields

rx: Receiver<TapPayload>

Receiving end of the session channel; the streaming task drains it.

captured: Arc<AtomicU64>

Events successfully queued for this session (delivered to the channel).

dropped: Arc<AtomicU64>

Events dropped because the session channel was full.

Trait Implementations

impl Drop for TapSessionHandle

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.