123456789101112131415161718192021222324252627282930313233343536373839 |
- package bus
- import "context"
- var (
- Default Bus
- )
- func init() {
- Default = NewInPrcBus(context.Background())
- }
- func SetGlobal(bus Bus) {
- Default = bus
- }
- func GetGlobal() Bus {
- return Default
- }
- func Publish(e *Event) {
- Default.Publish(e)
- }
- func Dispatch(e *Event) (err error) {
- return Default.Dispatch(e)
- }
- func DispatchCtx(ctx context.Context, e *Event) (err error) {
- return Default.DispatchCtx(ctx, e)
- }
- func Subscribe(sub Subscriber) (err error) {
- return Default.Subscribe(sub)
- }
- func UnSubscribe(sub Subscriber) (err error) {
- return Default.UnSubscribe(sub)
- }
|