RxJava from list with async wait for callback

Question

List<String> listExample = Arrays.asList("one", "two", "three");

Think of i have list of string, and using RxJava (Observable.fromArray)

Observable.fromArray(ids.toArray(new String[ids.size()])).subscribe(new Consumer<String>() {
    @Override
    public void accept(@NonNull String s) throws Exception {

    }
});

Here think each string has a Async callback here once i receive that callback it should move to next string. Is it possible using rxjava?

This is the code which i'am having currently, it doesn't wait for till the callback right!.

for (String id : ids) {
    getMessage(id, new urlGenCallback() {
        @Override
        public void urlAndToken(String url, String token, String idx) {

        }
    });
}

Thank you @Geoffrey Marizy

Answer: Check Below For More Info About ConcatMap Visit Here

Put you answer as an answer, not an edit of your question. Or improve the question which helped you get there. — tynn
– tynn, Commented Jun 7, 2017 at 13:32
Since the issue is solved, th stack-overflow way of doing things is to mark the answer which solved it as "accepted" — Geoffrey Marizy
– Geoffrey Marizy, Commented Jun 12, 2017 at 15:52

Geoffrey Marizy · Accepted Answer · 2017-06-07 12:37:03Z

1

You are looking to the concatMap operator. A complete article on this topic: https://fernandocejas.com/2015/01/11/rxjava-observable-tranformation-concatmap-vs-flatmap/

Wrap your request as an Observable, then pass it as a parameter to concatMap :

Observable.fromArray(ids.toArray(new String[ids.size()])).concatMap(/* your request returning an Observable */)

answered Jun 7, 2017 at 12:37

Geoffrey Marizy

5,5712 gold badges28 silver badges31 bronze badges

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

Comments

Raj · Accepted Answer · 2017-06-07 13:37:02Z

Observable.fromArray(ids.toArray(new String[ids.size()]))
        .concatMap(s -> {
            return Observable.create(new ObservableOnSubscribe<String>() {
                @Override
                public void subscribe(@NonNull ObservableEmitter<String> e) throws Exception {
                    getMessage(s, new urlGenCallback() {
                        @Override
                        public void urlAndToken(String url, String token, String id) {
                            e.onNext("......");
                            e.onComplete();
                        }
                    });
                }
            });
        }).subscribe(new Consumer<String>() {
    @Override
    public void accept(@NonNull String s) throws Exception {
       //All other code goes here
    }
});

Collectives™ on Stack Overflow

RxJava from list with async wait for callback

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