Hi, of course you should learn goroutines and channels first. However, I found using them very involved and I wrote rxgo because I wanted a more abstract and declarative way of dealing with reactive streams. I tried to develop the extension so it integrates seamlessly with conventional go code, and that means diverting away from reactiveX conventions here and there. For instance, a call to Subscribe returns a channel:

s := myObservable.Subscribe(myObserver)
<-s

Hope this helps.