An implementation of QueryObservable that works with RxJS - View it on GitHub