Struct rumqttlog::Connection

pub struct Connection {
    pub conn: ConnectionType,
    // some fields omitted
}

Used to register a new connection with the router Connection messages encompasses a handle for router to communicate with this connection

Fields

conn: ConnectionType

Kind of connection. A replicator connection or a device connection Replicator connection are only created from inside this library. All the external connections are of ‘device’ type

Implementations

impl Connection

pub fn new_remote(
    id: &str,
    clean: bool,
    capacity: usize
) -> (Connection, Receiver<Notification>)

pub fn new_replica(
    id: usize,
    clean: bool,
    capacity: usize
) -> (Connection, Receiver<Notification>)

pub fn clean(&self) -> bool

pub fn will(&mut self) -> Option<LastWill>

pub fn set_will(&mut self, will: LastWill)

pub fn notify(&mut self, notification: Notification) -> bool

Sends notification and returns status to unschedule this connection

Trait Implementations

impl Debug for Connection

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

Formats the value using the given formatter.