eventbus

Overview ¶

Package eventbus 提供进程内、按主题(topic)分发的泛型事件总线:发布者按 topic 发事件,订阅者按 topic 注册回调处理函数,解耦"谁发"与"谁收"。

与 pkg/stream 的区别(互补):

• stream.Broadcaster 是单一数据源的 channel 扇出——所有订阅者收到同一份流, 订阅者用 range channel 消费,适合 SSE/WebSocket"一份数据推给 N 个连接";
• eventbus 是多主题、回调式——订阅者只收自己关心的 topic,处理逻辑写在回调里, 适合"模块间事件解耦"(presence 上线事件 → 通知模块 + 审计模块各自订阅)。

泛型 T 为事件负载类型。分发模式:

• 同步(默认):Publish 在调用方 goroutine 里依次执行所有 handler,返回即处理完;
• 异步(WithAsync):每个 handler 在独立 goroutine 执行(pkg/safe 恢复 panic), Publish 不阻塞。同步模式下 handler 的 panic 也被恢复,不影响其它 handler。

并发安全。零值不可用,用 New 构造。