Struct EventPublisher 

pub struct EventPublisher { /* private fields */ }

Broadcasts Events to registered EventSubscribers.

Each subscriber is paired with an event type filter at subscription time. Only matching events are dispatched. Each call runs in a spawned task so that slow subscribers do not block the engine.

Examples

use ironflow_engine::notify::{EventPublisher, WebhookSubscriber, Event};

let mut publisher = EventPublisher::new();
publisher.subscribe(
    WebhookSubscriber::new("https://hooks.example.com/events"),
    &[Event::RUN_STATUS_CHANGED, Event::STEP_FAILED],
);

Implementations

impl EventPublisher

pub fn new() -> Self

Create an empty publisher with no subscribers.

Examples

use ironflow_engine::notify::EventPublisher;

let publisher = EventPublisher::new();
assert_eq!(publisher.subscriber_count(), 0);

pub fn subscribe( &mut self, subscriber: impl EventSubscriber + 'static, event_types: &[&'static str], )

Register a subscriber with an event type filter.

The subscriber is called only for events whose event_type() is in event_types. Pass Event::ALL to receive every event.

Use the Event::* constants for the filter values.

Examples

use ironflow_engine::notify::{EventPublisher, WebhookSubscriber, Event};

let mut publisher = EventPublisher::new();

// Only on specific event types:
publisher.subscribe(
    WebhookSubscriber::new("https://example.com/hook"),
    &[Event::RUN_STATUS_CHANGED, Event::STEP_FAILED],
);

// On all events:
publisher.subscribe(
    WebhookSubscriber::new("https://example.com/all"),
    Event::ALL,
);

pub fn subscriber_count(&self) -> usize

Number of registered subscribers.

pub fn publish(&self, event: Event)

Broadcast an event to all matching subscribers.

Each matching subscriber runs in its own spawned task. This method returns immediately and never blocks.

Trait Implementations

impl Default for EventPublisher

fn default() -> Self

Returns the “default value” for a type.