RxJS adaptor for Ractive