EventBus

EventBus

Package EventBus 是一个小巧而轻量级的事件总线,支持 GoLang 的异步兼容性。

安装

请确保您的计算机上安装了 Go。 在终端中键入以下命令: 去获取 GitHub.com/asaskevich/EventBus 之后,包就可以使用了。

在项目中导入包

在您的 *.go 文件中添加以下一行:

import "github.com/asaskevich/EventBus"

如果您不喜欢使用长的 EventBus, 可以这样做:

import (
	evbus "github.com/asaskevich/EventBus"
)

示例

func calculator(a int, b int) {
	fmt.Printf("%d\n", a + b)
}

func main() {
	bus := EventBus.New();
	bus.Subscribe("main:calculator", calculator);
	bus.Publish("main:calculator", 20, 40);
	bus.Unsubscribe("main:calculator", calculator);
}

实现的方法

• New()
• Subscribe()
• SubscribeOnce()
• HasCallback()
• Unsubscribe()
• Publish()
• SubscribeAsync()
• SubscribeOnceAsync()
• WaitAsync()

New() 返回一个新的 EventBus，其中包含空的处理程序。

Publish(topic string, args ...interface{})

Publish 执行为主题定义的回调函数。任何其他参数都会传递给回调函数。