Struct DogEventHub 

pub struct DogEventHub<R, P>
where
    R: Send + 'static,
    P: Send + Clone + 'static,
{ /* private fields */ }

Minimal runtime-agnostic event hub.

IMPORTANT DESIGN:

• We do NOT want callers to need &mut DogEventHub just to emit, because DogApp holds this behind an RwLock.
• We also do NOT want to hold a lock across .await.

So we split emission into:

1. snapshot (read-only, no await)
2. await listeners (no lock held)
3. cleanup once-listeners (write-lock, no await)

Implementations

impl<R, P> DogEventHub<R, P>

where R: Send + 'static, P: Send + Clone + 'static,

pub fn new() -> Self

pub fn set_publish(&mut self, f: PublishFn<R, P>)

pub fn clear_publish(&mut self)

pub fn on_exact( &mut self, path: impl Into<String>, event: ServiceEventKind, listener: EventListener<R, P>, ) -> ListenerId

Exact: app.on(“messages”, Created, …)

pub fn on_pattern( &mut self, pattern: ServiceEventPattern, listener: EventListener<R, P>, ) -> ListenerId

Sugar: app.on_str(“messages.created”, …)

pub fn once_pattern( &mut self, pattern: ServiceEventPattern, listener: EventListener<R, P>, ) -> ListenerId

Feathers-ish: once(…)

pub fn off(&mut self, id: ListenerId) -> bool

removeListener/off

pub fn remove_all(&mut self, pattern: Option<&ServiceEventPattern>) -> usize

removeAllListeners (optionally scoped)

pub fn snapshot_emit<'a>( &'a self, path: &str, event: &ServiceEventKind, data: &ServiceEventData<'a, R>, ctx: &HookContext<R, P>, ) -> (Vec<EventListener<R, P>>, Vec<ListenerId>)

Phase 1: snapshot matching listeners + remember which once listener ids to remove.

NOTE: no .await here, so it’s safe under a read-lock.

pub fn finalize_once_removals(&mut self, once_ids: &[ListenerId])

Phase 3: remove once listeners after emit finishes.

NOTE: no .await, safe under a write-lock.

pub async fn emit_async( &mut self, path: &str, event: &ServiceEventKind, data: &ServiceEventData<'_, R>, ctx: &HookContext<R, P>, ) -> Result<()>

Optional convenience if you ever hold &mut self directly (tests, single-thread use, etc.) This keeps the original API, but it is NOT required by DogApp anymore.

Trait Implementations

impl<R, P> Default for DogEventHub<R, P>

where R: Send + 'static, P: Send + Clone + 'static,

fn default() -> Self

Returns the “default value” for a type.