Struct NotificationSubscriptionView 

pub struct NotificationSubscriptionView<'a> {
    pub owner_id: [u8; 16],
    pub session_id: u64,
    pub wake_port: u16,
    pub next_sequence: u64,
    pub position: u64,
    /* private fields */
}

An empty channel list removes the listener. Other changes end its SQL transaction and preserve the committed queue cursor captured before publication.

Fields

owner_id: [u8; 16]

session_id: u64

wake_port: u16

next_sequence: u64

position: u64

Implementations

impl<'a> NotificationSubscriptionView<'a>

pub const fn is_unlisten(&self) -> bool

pub fn channels_json( &self, control: &StorageReadControl, ) -> VersionResult<BudgetedVec<u8>>

Reuse the common controlled JSON writer for registries that store a channel array. Iteration borrows the original record; only the encoded JSON buffer is allocated.

pub fn channels(&self) -> impl Iterator<Item = VersionResult<&'a str>> + 'a

Trait Implementations

impl<'a> Clone for NotificationSubscriptionView<'a>

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<'a> Copy for NotificationSubscriptionView<'a>