Method publish

crates/opencode-core/src/bus.rs:47–68

(&self, def: &BusEventDef, properties: serde_json::Value)

    }

    pub async fn publish(&self, def: &BusEventDef, properties: serde_json::Value) {
        tracing::info!(event_type = def.event_type, "publishing event");

        let event = BusEvent {
            event_type: def.event_type.to_string(),
            properties: properties.clone(),
        };

        let _ = self.tx.send(event.clone());

        let subscribers = self.subscribers.read().await;
        if let Some(subs) = subscribers.get(def.event_type) {
            for sub in subs {
                (sub.callback)(def.event_type, properties.clone());
            }
        }

        let wildcard = self.wildcard_subscribers.read().await;
        for sub in wildcard.iter() {
            (sub.callback)(def.event_type, properties.clone());
        }
    }

    pub async fn subscribe<F>(&self, def: &BusEventDef, callback: F) -> u64
    where