Use with changefeeds?

[GeoffreyPlitt]

Does this work with changefeeds?

[tjmehta]

Yup, works with all rethinkdb cursors

[GeoffreyPlitt]

Well, changefeeds have no end/close, so would the onCompleted() ever get called?

I'd like to use the toArray() behavior of non-changefeed-cursors, but with changefeeds, instead of using each() logic.

[tjmehta]

Exactly! 'onCompleted' will never be called with changefeed cursors. You will have to dispose the subscription to close the cursor. Also keep in mind, this inherits from the base Observable (not ConnectableObservable). I am not sure if your familiar with connectable observables and rxjs. To subscribe to the observable multiple times you'll probably use 'publish().refCount()'.

[GeoffreyPlitt]

Gotcha, thanks.

[tjmehta]

I don't fully understand what you're wanting out of toArray(), but assuming you know some scenario where you want to stop listening to the changefeed.. I'm sure there is an rxjs observable operator that trigger 'completed' after it receives a certain number of results or passes some test.

[tjmehta]

Or obviously, just unsubscribe after you get the last result you want.