Add support for RxJS observables

Closes #3