Event-D

Event-D 是基于事件驱动理念的事件总线实现, 用于代码解耦

Features

1. 支持泛型
2. 支持正则匹配事件和同时订阅多个事件
3. 链式回调，支持同步或异步触发回调
4. 可以方便地取消订阅事件

Example

test code

funcTestEventBus(t*testing.T) {
bus:=new(EventBus[int])
cancelDivide, err:=bus.Subscribe(func(eventstring, iint) bool {
fmt.Println("divide", event, i, "to", i/2) // 回调函数中获得事件名和参数returntrue
}, On("put")) // 订阅 put 事件iferr!=nil {
t.Error(err)
}
cancelCheck, _:=bus.Subscribe(func(eventstring, iint) bool {
fmt.Println("check", event, i)
ifi!=0 {
returntrue
} else {
bus.Emit("check failed", i) // 在回调中再触发其他事件returnfalse// 阻止事件向后传播
}
}, On("put"), Weight(math.MaxInt)) // 同步调用，调用优先级最高_, _=bus.Subscribe(func(eventstring, iint) bool {
fmt.Println("log", event, i)
returntrue
}, On(".*"), Async) // 订阅所有事件（不包含换行），异步调用bus.Emit("put", 0)
bus.Emit("put", 2)
time.Sleep(time.Millisecond*10)
cancelDivide() // 取消回调订阅cancelCheck()
bus.Emit("put", 4)
time.Sleep(time.Millisecond*10)
}

output

=== RUN TestEventBus
log put 2
check put 0
log check failed 0
check put 2
divide put 2 to 1
log put 0
log put 4
check put 4
--- PASS: TestEventBus (0.03s)