parkghost/eventbus

Concurrent eventbus library written in go

EventBus

a concurrent eventbus library written in go

Example:

var start, end sync.WaitGroup

//Define a event which implements eventbus.Event interface
type SimpleEvent struct{}

func (self *SimpleEvent) Event() string { return "" }

//SubscriberOne use HandlerFunc for subscribe to main.SimpleEvent
func SubscriberOne() {
	eventbus.SubscribeFunc(&SimpleEvent{}, func(evt eventbus.Event) {
		fmt.Printf("SubscriberOne receives event %T\n", evt)
		end.Done()
	})
	start.Done()
}

//SubscriberTwo use Channel for subscribe to main.SimpleEvent
func SubscriberTwo() {
	ch := eventbus.NewChannel()
	eventbus.Subscribe(&SimpleEvent{}, ch)
	start.Done()
	fmt.Printf("SubscriberTwo receives event %T\n", <-ch.C)
	end.Done()
}

func main() {
	start.Add(2)
	end.Add(2)

	go SubscriberOne()
	go SubscriberTwo()

	start.Wait()

	//To publish main.SimpleEvent to eventbus and then eventbus will notify who has subscribed to this type of event
	eventbus.Publish(&SimpleEvent{})

	end.Wait()
}

output

$ go run example/eventbus_example.go
SubscriberOne receives event *main.SimpleEvent
SubscriberTwo receives event *main.SimpleEvent

Authors

Brandon Chen

• http://brandonc.me
• http://github.com/parkghost

License

This project is licensed under the MIT license