mirror of
https://github.com/wonli/aqi.git
synced 2025-12-24 10:40:58 +08:00
14 lines
240 B
Go
14 lines
240 B
Go
package ws
|
|
|
|
func Pub(topic string, data any) {
|
|
Hub.PubSub.Pub(topic, data)
|
|
}
|
|
|
|
func Sub(topicId string, user *User) {
|
|
Hub.PubSub.Sub(topicId, user)
|
|
}
|
|
|
|
func SubFunc(topicId string, f func(msg *TopicMsg)) {
|
|
Hub.PubSub.SubFunc(topicId, f)
|
|
}
|