How to listen for changes to an int in RxJava?

Question

Java

There is a variable
int counterr = 0;
There is a loop

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

How to use RxJava to listen for changes in counterrand call some function each time?

Answer 1

For reference

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);   //менять так        
}