README
¶
Vardius - message-bus
Go simple async message bus.
ABOUT
Contributors:
Want to contribute ? Feel free to send pull requests!
Have problems, bugs, feature ideas? We are using the github issue tracker to manage them.
HOW TO USE
Basic example
package main
import (
"fmt"
"github.com/vardius/message-bus"
)
func main() {
bus := messagebus.New()
var wg sync.WaitGroup
wg.Add(2)
bus.Subscribe("topic", func(v bool) {
defer wg.Done()
fmt.Println(v)
})
bus.Subscribe("topic", func(v bool) {
defer wg.Done()
fmt.Println(v)
})
bus.Publish("topic", true)
wg.Wait()
}
License
This package is released under the MIT license. See the complete license in the package:
Documentation
¶
Overview ¶
Package messagebus provides simple async message publisher
Basic example:
package main
import (
"fmt"
"github.com/vardius/message-bus"
)
func main() {
bus := messagebus.New()
var wg sync.WaitGroup
wg.Add(2)
bus.Subscribe("topic", func(v bool) {
defer wg.Done()
fmt.Println(v)
})
bus.Subscribe("topic", func(v bool) {
defer wg.Done()
fmt.Println(v)
})
bus.Publish("topic", true)
wg.Wait()
}
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
Source Files
Click to show internal directories.
Click to hide internal directories.