Struct SubscriptionHandler 

pub struct SubscriptionHandler { /* private fields */ }

Manages a peer’s subscription to this node’s reactor.

This handler owns both the ReactorSubscription and the SubscriptionGuard for listening to changes on that subscription.

Implementations

impl SubscriptionHandler

pub fn new<SE, PA>(peer_id: EntityId, node: &Node<SE, PA>) -> Self

where SE: StorageEngine + Send + Sync + 'static, PA: PolicyAgent + Send + Sync + 'static,

pub fn subscription_id(&self) -> ReactorSubscriptionId

Get the subscription ID for this peer.

pub fn subscription(&self) -> &ReactorSubscription

Get a reference to the subscription for adding/removing predicates.

pub fn remove_predicate( &self, query_id: QueryId, ) -> Result<(), SubscriptionError>

Remove a predicate from this peer’s subscription.

pub async fn subscribe_query<SE, PA>( &self, node: &Node<SE, PA>, query_id: QueryId, collection_id: CollectionId, selection: Selection, cdata: &PA::ContextData, version: u32, known_matches: Vec<KnownEntity>, ) -> Result<NodeResponseBody>

where SE: StorageEngine + Send + Sync + 'static, PA: PolicyAgent + Send + Sync + 'static,

Handle a subscription request for this peer.