Nsryjdtyk

 List<Integer> list = new ArrayList<Integer>();

    for(int j=1;j<=3;j++)

        list.add(j);





    Observable<Integer> observable = Observable.fromIterable(list)

    .replay()

    .autoConnect();







    observable.subscribe(new Consumer<Integer>() {

        @Override

        public void accept(Integer integer) throws Exception {

            Log.v("consumer1:", ""+integer);

        }

    });





    observable.subscribe(new Consumer<Integer>() {

@Override

public void accept(Integer integer) throws Exception {

    Log.v("consumer2:", ""+integer);



}

});







    observable.subscribe(new Consumer<Integer>() {

        @Override

        public void accept(Integer integer) throws Exception {

            Log.v("consumer3:", ""+integer);

        }

    });

when i run the above code i get the following output:

consumer1:: 1

consumer1:: 2

consumer1:: 3

consumer2:: 1

consumer2:: 2

consumer2:: 3

consumer3:: 1

consumer3:: 2

consumer3:: 3

i was expecting replay to actually "replay" all the history that occurred before. so i was expecting to emit all the streams that occurred before. specially this is the output i expected:

//first time nothing to replay so just do the work

consumer1:: 1

consumer1:: 2

consumer1:: 3



//replay consumer1 stream:,

consumer2:: 1

consumer2:: 2

consumer2:: 3

//already replayed now do the work

consumer2:: 1

consumer2:: 2

consumer2:: 3



//replay consumer1 stream:

consumer3:: 1

consumer3:: 2

consumer3:: 3



//replay consumer2 stream:

consumer3:: 1

consumer3:: 2

consumer3:: 3

//now do the work

consumer3:: 1

consumer3:: 2

consumer3:: 3

this is what i am expecting to happen with replay. what am i doing wrong ? its like its not even working now the way i have it.

Not sure why you wanted this exotic behavior, but you can repeat with an ever increasing number:

List<Integer> list = new ArrayList<Integer>();

for (int j = 1; j <= 3; j++) {

    list.add(j);

}





AtomicInteger count = new AtomicInteger();



Observable<Integer> observable = 

    Observable.defer(() -> {

        Observable.fromIterable(list)

        .replay()

        .autoConnect()

        .repeat(count.incrementAndGet());

    });



observable.subscribe(new Consumer<Integer>() {

    @Override

    public void accept(Integer integer) throws Exception {

        Log.v("consumer1:", ""+integer);

    }

});



observable.subscribe(new Consumer<Integer>() {

    @Override

    public void accept(Integer integer) throws Exception {

        Log.v("consumer2:", "" + integer);

    }

});



observable.subscribe(new Consumer<Integer>() {

    @Override

    public void accept(Integer integer) throws Exception {

        Log.v("consumer3:", ""+integer);

    }

});