Struct Subscriber 

pub struct Subscriber { /* private fields */ }

One session’s standing interest in being told that a list changed.

Built once, when the session registers, and read on every publish after that. Holding the FeatureProfile by value rather than by reference is deliberate: it is a u128 bitset that FeatureProfile derives Copy for, and a subscriber that outlives its session must not borrow one.

Implementations

impl Subscriber

pub fn new( kind: PrimitiveKind, feature: Feature, method: &'static str, frame: &str, profile: FeatureProfile, sink: Arc<dyn DynFrameSink>, ) -> Self

A subscriber for kind, gated on feature, told with method.

frame is the encoded notification. It is built once here rather than per publish because the bytes are identical for every session receiving it, and encoding a notification per subscriber turns one publish into one serialisation per session — which is the difference between a fan-out that costs a socket write and one that costs a JSON encode.

pub const fn also_for(self, kind: PrimitiveKind) -> Self

The same subscriber, also told when kind changes.

For a notification that names more than one kind — see the field’s own comment for the one MCP has.

pub const fn kind(&self) -> PrimitiveKind

The kind of primitive this subscriber wants to hear about.

pub fn covers(&self, kinds: &[PrimitiveKind]) -> bool

Whether a publish that touched kinds concerns this subscriber.

pub const fn method(&self) -> &'static str

The method this subscriber is notified with.

pub fn is_eligible(&self) -> bool

Whether this subscriber’s negotiated profile permits the notification.

The one place the gate is decided, so there is no second caller that forgets to ask.

Trait Implementations

impl Clone for Subscriber

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for Subscriber

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

Formats the value using the given formatter.