RxGo : Reactive programming in Go