Use rxjava2 to loop through an arraylist

Question

I have an arraylist which contains a set of objects.I would like to use rxjava so i can loop through the list in such a way that in the onSubscribe method instead of getting the entire list at once i get each list item 1 at a time

That's almost at the top of every RXJava example… try a search engine for once! :) — Martin Marconcini
– Martin Marconcini, Commented Mar 3, 2017 at 19:10

Jude Fernandes · Accepted Answer · 2017-03-03 19:42:04Z

5

It was actually Observable.fromIterable that did the trick, Observable.from returns the entire array at a time.

answered Mar 3, 2017 at 19:42

Jude Fernandes

7,54512 gold badges57 silver badges93 bronze badges

Sign up to request clarification or add additional context in comments.

Comments

YoloAcc · Accepted Answer · 2018-03-28 13:43:12Z

0

If you are on android it is recommended to use retrolambda and rxandroid too. You can remove filter ofc. This line: .subscribeOn(Schedulers.newThread()) is for android only too.

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

array.add(0);
array.add(1);
array.add(2);
array.add(5);
array.add(10);

Observable.fromIterable(array)
    .subscribeOn(Schedulers.newThread())
    .filter(integer -> integer % 2 == 0)
    .subscribe(integer -> Log.e(TAG, "" + integer));

answered Mar 28, 2018 at 13:43

YoloAcc

891 gold badge1 silver badge10 bronze badges

Collectives™ on Stack Overflow

Use rxjava2 to loop through an arraylist

2 Answers 2

Comments

Comments

Your Answer

Hot Network Questions

Collectives™ on Stack Overflow

2 Answers 2

Comments

Comments

Your Answer

Sign up or log in

Post as a guest

Related