Enum reactive_messaging::prelude::ConnectionEvent

pub enum ConnectionEvent<const BUFFERED_MESSAGES_PER_PEER_COUNT: usize, LocalPeerMessages: 'static + Send + Sync + PartialEq + Debug + ReactiveMessagingSerializer<LocalPeerMessages>> {
    PeerConnected {
        peer: Arc<Peer<BUFFERED_MESSAGES_PER_PEER_COUNT, LocalPeerMessages>>,
    },
    PeerDisconnected {
        peer: Arc<Peer<BUFFERED_MESSAGES_PER_PEER_COUNT, LocalPeerMessages>>,
        stream_stats: Arc<StreamExecutor>,
    },
    ApplicationShutdown {
        timeout_ms: u32,
    },
}

The internal events a reactive processor (for a server or client) shares with the user code.
The user code may use those events to maintain a list of connected clients, be notified of stop/close/quit requests, init/deinit sessions, etc. Note that the Peer objects received in those events may be used, at any time, to send messages to the clients – like “Shutting down. Goodbye”. When doing this on other occasions, make sure you won’t break your own protocol.

Variants

PeerConnected

Fields

peer: Arc<Peer<BUFFERED_MESSAGES_PER_PEER_COUNT, LocalPeerMessages>>

PeerDisconnected

Fields

peer: Arc<Peer<BUFFERED_MESSAGES_PER_PEER_COUNT, LocalPeerMessages>>

stream_stats: Arc<StreamExecutor>

ApplicationShutdown

Fields

timeout_ms: u32

Trait Implementations

impl<const BUFFERED_MESSAGES_PER_PEER_COUNT: usize, LocalPeerMessages: Debug + 'static + Send + Sync + PartialEq + Debug + ReactiveMessagingSerializer<LocalPeerMessages>> Debug for ConnectionEvent<BUFFERED_MESSAGES_PER_PEER_COUNT, LocalPeerMessages>

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

Formats the value using the given formatter.