Struct NetworkEventBus 

pub struct NetworkEventBus { /* private fields */ }

Synchronous in-process publish-subscribe bus for NetworkEvents.

Example

use ipfrs_network::event_bus::{NetworkEventBus, NetworkEvent, EventFilter};

let mut bus = NetworkEventBus::new();
let id = bus.subscribe(EventFilter::PeerEvents);

bus.publish(NetworkEvent::PeerConnected {
    peer_id: "peer1".into(),
    address: "/ip4/1.2.3.4/tcp/4001".into(),
});

let events = bus.drain(id);
assert_eq!(events.len(), 1);

Implementations

impl NetworkEventBus

pub fn new() -> Self

Create a new, empty NetworkEventBus.

pub fn subscribe(&mut self, filter: EventFilter) -> u64

Subscribe to events matching filter.

Returns a unique subscription id that can be used to drain events or unsubscribe later.

pub fn unsubscribe(&mut self, id: u64) -> bool

Remove the subscription identified by id.

Returns true if the subscription existed, false otherwise.

pub fn publish(&mut self, event: NetworkEvent)

Publish an event to all matching subscribers.

Each matching subscriber receives its own clone of event. If a subscriber’s queue is full (>= 200 entries) the event is dropped and both the per-subscription and global drop counters are incremented.

pub fn drain(&mut self, id: u64) -> Vec<NetworkEvent>

Drain all buffered events for the subscription identified by id.

Returns an empty Vec if the id does not exist.

pub fn peek_count(&self, id: u64) -> usize

Return the number of events currently buffered for subscription id.

Returns 0 for unknown ids.

pub fn stats(&self) -> BusStats

Return a snapshot of the current bus statistics.

pub fn clear_all_queues(&mut self)

Drain all queues for all active subscriptions, discarding pending events.

Trait Implementations

impl Debug for NetworkEventBus

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

Formats the value using the given formatter.

impl Default for NetworkEventBus

fn default() -> NetworkEventBus

Returns the “default value” for a type.