I see from a closed issue in 2013 that fromNodeCallback should be a cold observable. But the current version is not cold. I have to convert it to cold by doing something like:
fn = rx.Observable.fromNodeCallback(x)
var obs = rx.Observable.just(1).flatMap(function() { return fn() })
There seems to be a more recent issue (#818). Maybe this should be discussed there. Either way, I agree with you. It should definitely be a cold observable.
I see from a closed issue in 2013 that fromNodeCallback should be a cold observable. But the current version is not cold. I have to convert it to cold by doing something like:
fn = rx.Observable.fromNodeCallback(x)
var obs = rx.Observable.just(1).flatMap(function() { return fn() })
Is this intended?