Struct EventBus 

pub struct EventBus { /* private fields */ }

Event bus for TAP HTTP server

Implementations

impl EventBus

pub fn new() -> Self

Create a new event bus

pub fn subscribe<S>(&self, subscriber: S)

where S: EventSubscriber + 'static,

Subscribe to HTTP events with a boxed subscriber

pub fn unsubscribe(&self, subscriber: &Arc<Box<dyn EventSubscriber>>)

Remove a subscriber from the event bus

pub async fn publish_server_started(&self, address: String)

Publish a server started event

pub async fn publish_server_stopped(&self)

Publish a server stopped event

pub async fn publish_request_received( &self, method: String, path: String, client_ip: Option<String>, )

Publish a request received event

pub async fn publish_response_sent( &self, status: StatusCode, size: usize, duration_ms: u64, )

Publish a response sent event

pub async fn publish_message_received( &self, id: String, type_: String, from: Option<String>, to: Option<String>, )

Publish a DIDComm message received event

pub async fn publish_message_error( &self, error_type: String, message: String, message_id: Option<String>, )

Publish a DIDComm message processing error event

pub fn subscriber_count(&self) -> usize

Get the number of subscribers (for testing)

Trait Implementations

impl Default for EventBus

fn default() -> Self

Returns the “default value” for a type.