Add support for RxJS observables

**Note**: the tests don't run properly, I'm not sure what's going on, as my async knowledge isn't too good. It would be great if you could debug this.