Struct EventPublisher 

pub struct EventPublisher { /* private fields */ }

Publishes events to subscribers

Implementations

impl EventPublisher

pub fn new( subscriptions: Arc<RwLock<SubscriptionManager>>, socket: Arc<UdpSocket>, ) -> Self

Create a new event publisher

pub async fn publish_event<P: PayloadWireFormat>( &self, service_id: u16, instance_id: u16, event_group_id: u16, message: &Message<P>, ) -> Result<usize, Error>

Publish an event to all subscribers of an event group

Arguments

• service_id - Service ID
• instance_id - Instance ID
• event_group_id - Event group ID
• message - The SOME/IP message to send (must be a notification/event)

pub async fn publish_raw_event( &self, service_id: u16, instance_id: u16, event_group_id: u16, event_id: u16, request_id: u32, protocol_version: u8, interface_version: u8, payload: &[u8], ) -> Result<usize, Error>

Publish raw event data (already serialized with E2E protection)

This is useful when you’ve already applied E2E protection to the payload

pub async fn has_subscribers( &self, service_id: u16, instance_id: u16, event_group_id: u16, ) -> bool

Check if there are any active subscribers for a specific event group

Arguments

• service_id - Service ID
• instance_id - Instance ID
• event_group_id - Event group ID

Returns

true if there are subscribers, false otherwise

pub async fn subscriber_count( &self, service_id: u16, instance_id: u16, event_group_id: u16, ) -> usize

Get the current number of subscribers for a specific event group