Как слушать изменения в int в RxJava?

Question

[Elsh Yff]

Есть переменная
int counterr = 0;
Есть loop

for (int i=1;i<100;i++) {
   counter++;           
}

Как с помощью RxJava слушать изменения в counterr и каждый раз вызывать какую то функцию?

Answer 1

[Эмин]

Для справки

PublishSubject<Integer> counterSubject = PublishSubject.create();

counterSubject.subscribe(new Action1<Integer>() {
            @Override public void call(Integer integer) {
                // слушать тут
            }
        });

for (int i=1;i<100;i++) {
   counterSubject.onNext(i);   //менять так        
}

Comments

[Elsh Yff]

А где тут переменная counterr? Loop для примера написал. Нужна слушать изменение значения counterr'a

[Эмин]

Тогда вместо counterr'a используйте PublishSubject<Integer> counterSubject;
Соответсвенно когда хотите изменить его, делайте counterSubject.onNext(i);

[Эмин]

Вот, читайте reactivex.io/documentation/subject.html

[Elsh Yff]

Спасибо, то что искал