Struct Subscription 

pub struct Subscription {
    pub id: u64,
    pub peer_id: String,
    pub topic: MessageTopic,
    pub filter: SubscriptionFilter,
    pub created_at: u64,
    pub message_count: u64,
}

A subscriber registration in SubscriptionRouter.

The id is the FNV-1a hash of (peer_id + topic.0 + created_at.to_string()).

Fields

id: u64

Stable identifier for this subscription.

peer_id: String

Peer that owns this subscription.

topic: MessageTopic

Topic this subscription is interested in.

filter: SubscriptionFilter

Additional predicate applied after topic matching.

created_at: u64

Millisecond timestamp at which this subscription was created.

message_count: u64

Number of messages successfully delivered to this subscription.

Implementations

impl Subscription

pub fn new( peer_id: impl Into<String>, topic: MessageTopic, filter: SubscriptionFilter, created_at: u64, ) -> Self

Create a new Subscription, computing its id automatically.

Trait Implementations

impl Clone for Subscription

fn clone(&self) -> Subscription

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for Subscription

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

Formats the value using the given formatter.