Struct HookBus 

pub struct HookBus { /* private fields */ }

The central hook dispatcher.

Thread-safe: uses RwLock so multiple concurrent emitters can read the handler list, and registration takes a write lock only briefly.

Implementations

impl HookBus

pub fn new() -> Self

Create an empty HookBus with no handlers.

pub async fn subscribe( &self, kind: HookKind, handler: Arc<dyn ExtensionHandler>, tool_filter: Option<String>, matcher: Option<HookMatcher>, permissions: PermissionSet, ) -> Result<(), String>

Register a handler for a specific hook kind.

Returns an error if the handler’s permissions don’t allow subscribing to this hook kind.

pub async fn emit(&self, event: &HookEvent) -> HookResult

Emit a hook event to all registered handlers.

Returns the first Block result if any handler blocks, otherwise returns Continue. Handlers are called in registration order.

If no handlers are registered for this hook, returns immediately (the no-extensions fast path).

pub async fn unsubscribe_all(&self, extension_id: &str)

Remove all handlers for a given extension ID.

pub async fn handler_count(&self) -> usize

Number of registered handlers across all hooks.

pub async fn is_empty(&self) -> bool

Check if any handlers are registered (for fast-path decisions).

pub async fn subscriptions_for( &self, extension_id: &str, ) -> Vec<(HookKind, Option<String>)>

Return all (kind, tool_filter) pairs subscribed by the given extension id. Sorted by kind name, then by tool_filter (None first), for stable output.

Trait Implementations

impl Default for HookBus

fn default() -> Self

Returns the “default value” for a type.