Module network_event_bus 

NetworkEventBus — synchronous publish-subscribe event bus for network events.

Provides topic-based routing, subscriber filtering, and event replay for late subscribers. All operations are synchronous and suitable for use from both synchronous and asynchronous contexts without spawning tasks.

Design

• Publishers call NetworkEventBus::publish to emit events.
• Consumers call NetworkEventBus::subscribe to register interest in events.
• Subscribers may specify an EventFilter to narrow the event stream.
• A configurable replay buffer retains recent events so that late subscribers can catch up via NetworkEventBus::replay_for_subscriber.
• No unwrap() is used anywhere in this module.

Structs

EventBusConfig

Configuration knobs for NetworkEventBus.

EventBusStats

A snapshot of bus-wide statistics.

NebNetworkEvent

A single network event, as published to the bus.

NebSubscription

Runtime state for a single subscriber.

NetworkEventBus

Synchronous, in-process publish-subscribe bus for network events.

SubscriberId

An opaque, monotonically increasing identifier for a subscription.

Enums

BusError

Errors returned by NetworkEventBus operations.

EventFilter

Determines which events are delivered to a particular subscriber.

EventTopic

Categorises the kind of network event being published.