Struct PubSubConnection

pub(crate) struct PubSubConnection {
    connection_id: usize,
    notifier: Sender<Result<ProtoPubSubMessage, Status>>,
    state: Arc<PubSubState>,
}

An active connection managed by PubSubState.

When dropped, removes itself from PubSubState, clearing all of its subscriptions.

Fields

connection_id: usize

notifier: Sender<Result<ProtoPubSubMessage, Status>>

state: Arc<PubSubState>

Trait Implementations

impl Debug for PubSubConnection

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

Formats the value using the given formatter.

impl Drop for PubSubConnection

fn drop(&mut self)

Executes the destructor for this type.

impl PubSubSenderInternal for PubSubConnection

fn push_diff(&self, shard_id: &ShardId, diff: &VersionedData)

Push a diff to subscribers.

fn subscribe(&self, shard_id: &ShardId)

Subscribe the corresponding PubSubReceiver to diffs for the given shard.

fn unsubscribe(&self, shard_id: &ShardId)

Unsubscribe the corresponding PubSubReceiver from diffs for the given shard.