These are chat archives for ReactiveX/RxJava

25th
May 2016
Simon Baslé
@simonbasle
May 25 2016 09:26
@dragantl is the dataObservable bounded? maybe you could simply zip it with an Observable.range(1, Integer.MAX_VALUE) (or whatever max expected length you might have)?
Lalit Maganti
@tilal6991
May 25 2016 10:50
@dragantl https://github.com/davidmoten/rxjava-extras - mapWithIndex may come in handy
Dorus
@Dorus
May 25 2016 10:51
@dragantl I filled #3602 before but it was rejected. So you have to stick with the zip thing.
Vadym
@dragantl
May 25 2016 17:37
@simonbasle, @tilal6991, @Dorus thank you very much! It is a bound observable. Also, thank so pointing me to the rxjava-extras and the issue.
Vadym
@dragantl
May 25 2016 20:55
@Dorus wanted to refer back to your answer https://gitter.im/ReactiveX/RxJava?at=572913d30149d6bb04b86b7b, I've been working on this for some time today, trying to figure out one issue, which you had pointed out, with dealing of empty values. That is, more specifically, location emits every second. Some sensors emit fast and usually result in a case that window will not be empty. However, some sensors emit less frequently. This results in an empty window. An empty window then results in Observable.zip not emitting until the slow sensor emits again
Sorry, I'm not sure how to link directly to the message timestamp
What I've been trying to do was to get a hold of the latest emission but i keep getting into situation where nothing good comes of it >_< Right now, I'm looking into BlockingObservable.latest()
Dorus
@Dorus
May 25 2016 22:43
@dragantl Might have time to look at this tomorrow :)
Vadym
@dragantl
May 25 2016 23:04
@Dorus oh man, I think withLatestFrom would have solved it but it looks like RxJava only implemented combination with only one observable and not variable arguments like RxJS has :(