RxJava question. I have an Observable that emits big decimal numbers

Question

RxJava question. I have an Observable that emits big decimal numbers

(or integers, doen'st matter actually). And I have a threshold value defined at observable composition time. Threshold is not going to change during observable life time, in other words.
What I need is to filter out values that differ from the last passed one within the threshold. Or rephrase it: pass value downstream only if it differs from the last passed one more than the threshold.
Example:
Source observable values:
[5, 4, 7, 9, 15, 14, 13, 12, 11, 7, 3, 2, 1]

Filetered values with threshold = 3 :
[5, 9, 15, 11, 7, 3]

To illustrate it better, lets assume that it's temperature readings, for example. I wan't to filter only those values where temperature changes more than 3 degree. The very first value always passes and serves as an initial value to compare to. If for example first temperature reading was 21 Celsius and within and hour each subsequent reading was in [18..24] then none of those values should pass downstream. But as soon as it gets over those bounds it shoud be passed and create new bounds to compare to.

The question is: does anyone knows a way to do this with RxJava operators only? Or there's no other way besides storing state outside rx pipeline (in volatile or atomic reference or any other synchronized state, details don't matter) ?

0

19.09.2018

1 ответов

24 просмотра

Dmytro Buryak · Answer 1

Dmytro Buryak Автор вопроса

Nevermind, problem solved with Observable.scan operator.

0

19.09.2018

Похожие чаты

RxJava question. I have an Observable that emits big decimal numbers

1 ответов

Похожие вопросы