a concurrent eventbus written in go