about rxjava request url











up vote
1
down vote

favorite












I have four Http Url, I need to try one by one.But there is a problem,when one of the url is error,the after url not call. The pseudocode like this:
i = 0;



 Observable.fromArray("http://www.baidu.com/", "http://www.google.com/", "https://www.bing.com/")
.concatMap(new Function<String, ObservableSource<String>>() {
@Override
public ObservableSource<String> apply(String s) throws Exception {
return Observable.create(new ObservableOnSubscribe<String>() {
@Override
public void subscribe(ObservableEmitter<String> emitter) throws Exception {
Log.i("settingsubscribe", i + "");
if (i == 1) {
emitter.onError(new Throwable("error"));

//emitter.onComplete();
} else {
emitter.onNext(s.concat("_1"));
emitter.onComplete();
}
i ++;
}
});
}
})

.subscribe(new Consumer<String>() {
@Override
public void accept(String s) throws Exception {
Log.i("settingfffff", s);
}
}, new Consumer<Throwable>() {
@Override
public void accept(Throwable throwable) throws Exception {
Log.i("settingfffff", throwable.getMessage());
}
}, new Action() {
@Override
public void run() throws Exception {
Log.i("settingfffff", "onComplete");
}
});


when i = 1,send the error and the event stoped, I hope continue, How can I do?










share|improve this question
























  • See reactivex.io/RxJava/2.x/javadoc/io/reactivex/…
    – akarnokd
    Nov 22 at 8:25















up vote
1
down vote

favorite












I have four Http Url, I need to try one by one.But there is a problem,when one of the url is error,the after url not call. The pseudocode like this:
i = 0;



 Observable.fromArray("http://www.baidu.com/", "http://www.google.com/", "https://www.bing.com/")
.concatMap(new Function<String, ObservableSource<String>>() {
@Override
public ObservableSource<String> apply(String s) throws Exception {
return Observable.create(new ObservableOnSubscribe<String>() {
@Override
public void subscribe(ObservableEmitter<String> emitter) throws Exception {
Log.i("settingsubscribe", i + "");
if (i == 1) {
emitter.onError(new Throwable("error"));

//emitter.onComplete();
} else {
emitter.onNext(s.concat("_1"));
emitter.onComplete();
}
i ++;
}
});
}
})

.subscribe(new Consumer<String>() {
@Override
public void accept(String s) throws Exception {
Log.i("settingfffff", s);
}
}, new Consumer<Throwable>() {
@Override
public void accept(Throwable throwable) throws Exception {
Log.i("settingfffff", throwable.getMessage());
}
}, new Action() {
@Override
public void run() throws Exception {
Log.i("settingfffff", "onComplete");
}
});


when i = 1,send the error and the event stoped, I hope continue, How can I do?










share|improve this question
























  • See reactivex.io/RxJava/2.x/javadoc/io/reactivex/…
    – akarnokd
    Nov 22 at 8:25













up vote
1
down vote

favorite









up vote
1
down vote

favorite











I have four Http Url, I need to try one by one.But there is a problem,when one of the url is error,the after url not call. The pseudocode like this:
i = 0;



 Observable.fromArray("http://www.baidu.com/", "http://www.google.com/", "https://www.bing.com/")
.concatMap(new Function<String, ObservableSource<String>>() {
@Override
public ObservableSource<String> apply(String s) throws Exception {
return Observable.create(new ObservableOnSubscribe<String>() {
@Override
public void subscribe(ObservableEmitter<String> emitter) throws Exception {
Log.i("settingsubscribe", i + "");
if (i == 1) {
emitter.onError(new Throwable("error"));

//emitter.onComplete();
} else {
emitter.onNext(s.concat("_1"));
emitter.onComplete();
}
i ++;
}
});
}
})

.subscribe(new Consumer<String>() {
@Override
public void accept(String s) throws Exception {
Log.i("settingfffff", s);
}
}, new Consumer<Throwable>() {
@Override
public void accept(Throwable throwable) throws Exception {
Log.i("settingfffff", throwable.getMessage());
}
}, new Action() {
@Override
public void run() throws Exception {
Log.i("settingfffff", "onComplete");
}
});


when i = 1,send the error and the event stoped, I hope continue, How can I do?










share|improve this question















I have four Http Url, I need to try one by one.But there is a problem,when one of the url is error,the after url not call. The pseudocode like this:
i = 0;



 Observable.fromArray("http://www.baidu.com/", "http://www.google.com/", "https://www.bing.com/")
.concatMap(new Function<String, ObservableSource<String>>() {
@Override
public ObservableSource<String> apply(String s) throws Exception {
return Observable.create(new ObservableOnSubscribe<String>() {
@Override
public void subscribe(ObservableEmitter<String> emitter) throws Exception {
Log.i("settingsubscribe", i + "");
if (i == 1) {
emitter.onError(new Throwable("error"));

//emitter.onComplete();
} else {
emitter.onNext(s.concat("_1"));
emitter.onComplete();
}
i ++;
}
});
}
})

.subscribe(new Consumer<String>() {
@Override
public void accept(String s) throws Exception {
Log.i("settingfffff", s);
}
}, new Consumer<Throwable>() {
@Override
public void accept(Throwable throwable) throws Exception {
Log.i("settingfffff", throwable.getMessage());
}
}, new Action() {
@Override
public void run() throws Exception {
Log.i("settingfffff", "onComplete");
}
});


when i = 1,send the error and the event stoped, I hope continue, How can I do?







java android rx-java






share|improve this question















share|improve this question













share|improve this question




share|improve this question








edited Nov 22 at 6:30









Milind Mevada

1,335617




1,335617










asked Nov 22 at 3:55









mars

61




61












  • See reactivex.io/RxJava/2.x/javadoc/io/reactivex/…
    – akarnokd
    Nov 22 at 8:25


















  • See reactivex.io/RxJava/2.x/javadoc/io/reactivex/…
    – akarnokd
    Nov 22 at 8:25
















See reactivex.io/RxJava/2.x/javadoc/io/reactivex/…
– akarnokd
Nov 22 at 8:25




See reactivex.io/RxJava/2.x/javadoc/io/reactivex/…
– akarnokd
Nov 22 at 8:25












1 Answer
1






active

oldest

votes

















up vote
0
down vote













emitter.onError(new Throwable("error"));



in above line of code, onError you are creating new Throwable, instead can you just log the error






share|improve this answer





















    Your Answer






    StackExchange.ifUsing("editor", function () {
    StackExchange.using("externalEditor", function () {
    StackExchange.using("snippets", function () {
    StackExchange.snippets.init();
    });
    });
    }, "code-snippets");

    StackExchange.ready(function() {
    var channelOptions = {
    tags: "".split(" "),
    id: "1"
    };
    initTagRenderer("".split(" "), "".split(" "), channelOptions);

    StackExchange.using("externalEditor", function() {
    // Have to fire editor after snippets, if snippets enabled
    if (StackExchange.settings.snippets.snippetsEnabled) {
    StackExchange.using("snippets", function() {
    createEditor();
    });
    }
    else {
    createEditor();
    }
    });

    function createEditor() {
    StackExchange.prepareEditor({
    heartbeatType: 'answer',
    convertImagesToLinks: true,
    noModals: true,
    showLowRepImageUploadWarning: true,
    reputationToPostImages: 10,
    bindNavPrevention: true,
    postfix: "",
    imageUploader: {
    brandingHtml: "Powered by u003ca class="icon-imgur-white" href="https://imgur.com/"u003eu003c/au003e",
    contentPolicyHtml: "User contributions licensed under u003ca href="https://creativecommons.org/licenses/by-sa/3.0/"u003ecc by-sa 3.0 with attribution requiredu003c/au003e u003ca href="https://stackoverflow.com/legal/content-policy"u003e(content policy)u003c/au003e",
    allowUrls: true
    },
    onDemand: true,
    discardSelector: ".discard-answer"
    ,immediatelyShowMarkdownHelp:true
    });


    }
    });














    draft saved

    draft discarded


















    StackExchange.ready(
    function () {
    StackExchange.openid.initPostLogin('.new-post-login', 'https%3a%2f%2fstackoverflow.com%2fquestions%2f53423652%2fabout-rxjava-request-url%23new-answer', 'question_page');
    }
    );

    Post as a guest















    Required, but never shown

























    1 Answer
    1






    active

    oldest

    votes








    1 Answer
    1






    active

    oldest

    votes









    active

    oldest

    votes






    active

    oldest

    votes








    up vote
    0
    down vote













    emitter.onError(new Throwable("error"));



    in above line of code, onError you are creating new Throwable, instead can you just log the error






    share|improve this answer

























      up vote
      0
      down vote













      emitter.onError(new Throwable("error"));



      in above line of code, onError you are creating new Throwable, instead can you just log the error






      share|improve this answer























        up vote
        0
        down vote










        up vote
        0
        down vote









        emitter.onError(new Throwable("error"));



        in above line of code, onError you are creating new Throwable, instead can you just log the error






        share|improve this answer












        emitter.onError(new Throwable("error"));



        in above line of code, onError you are creating new Throwable, instead can you just log the error







        share|improve this answer












        share|improve this answer



        share|improve this answer










        answered Nov 22 at 5:59







        user7154703





































            draft saved

            draft discarded




















































            Thanks for contributing an answer to Stack Overflow!


            • Please be sure to answer the question. Provide details and share your research!

            But avoid



            • Asking for help, clarification, or responding to other answers.

            • Making statements based on opinion; back them up with references or personal experience.


            To learn more, see our tips on writing great answers.





            Some of your past answers have not been well-received, and you're in danger of being blocked from answering.


            Please pay close attention to the following guidance:


            • Please be sure to answer the question. Provide details and share your research!

            But avoid



            • Asking for help, clarification, or responding to other answers.

            • Making statements based on opinion; back them up with references or personal experience.


            To learn more, see our tips on writing great answers.




            draft saved


            draft discarded














            StackExchange.ready(
            function () {
            StackExchange.openid.initPostLogin('.new-post-login', 'https%3a%2f%2fstackoverflow.com%2fquestions%2f53423652%2fabout-rxjava-request-url%23new-answer', 'question_page');
            }
            );

            Post as a guest















            Required, but never shown





















































            Required, but never shown














            Required, but never shown












            Required, but never shown







            Required, but never shown

































            Required, but never shown














            Required, but never shown












            Required, but never shown







            Required, but never shown







            Popular posts from this blog

            A CLEAN and SIMPLE way to add appendices to Table of Contents and bookmarks

            Calculate evaluation metrics using cross_val_predict sklearn

            Insert data from modal to MySQL (multiple modal on website)