Reactive Extensions implementation for the Go Programming Language