I am using observable-fns (which can also work with threads.js). Not sure how powerful RxJS and RxJava can be…

Still missing one important feature though, cancellability.

I am working on SQLite-SQLite and SQLite-MongoDB syncing.