RxAndroid operator retryWhen is invoked but does not resubscribe
.everyoneloves__top-leaderboard:empty,.everyoneloves__mid-leaderboard:empty,.everyoneloves__bot-mid-leaderboard:empty{ height:90px;width:728px;box-sizing:border-box;
}
API class using Retrofit
class interface TestApi {
@GET("/path/abc/xyz")
fun get(): Single
}
UseCase class
fun getResult(): Single {
return testApi.get()
.map{ response ->
val type = response.type
when(type){
null -> throw Exception()
else -> response
}
}
.retryWhen{ throwableHandler ->
throwableHandler.flatMap {
when(it) {
is Exception() -> Flowable.error(it)
else -> Flowable.timer(3,TimeUnit.SECONDS)
}
}
}
.timeout(60, TimeUnit.SECONDS)
}
MainClass.kt
usecase.getResult()
.subscribeOn(Schedulers.io())
.observeOn(AndroidSchedulers.mainThread())
.subscribeBy(onError = {Log.d(TAG,"Error")},
onSuccess = {Log.d(TAG,"Next")})
When app run :
If api return NULL, retryWhen() will be invoked then api is called again.
Event not timeout reached and api return Not NUL result -> onSuccess is called. This is correctly processing of retryWhen() operator in rxJava.
My Problem:
If I write some test method (to pretend API Retrofit) in MainClass.kt looks like below:
private fun testPretend(): Single<Animal> {
return Single.just(Animal)
}
MainClass.kt looks like:
testPretend()
.subscribeOn(Schedulers.io())
.observeOn(AndroidSchedulers.mainThread())
.subscribeBy(onError = {Log.d(TAG,"Error")},
onSuccess = {Log.d(TAG,"Next")})
So event retryWhen is invoked , testPretend() method is not called again.
What is the problem here?
And what is difference between Single return by testPrerend() and Retrofit API ?
retrofit observable retrofit2 rx-java2 rx-android
asked Nov 29 '18 at 6:26
miho39miho39
194521
add a comment |
API class using Retrofit
class interface TestApi {
@GET("/path/abc/xyz")
fun get(): Single
}
UseCase class
fun getResult(): Single {
return testApi.get()
.map{ response ->
val type = response.type
when(type){
null -> throw Exception()
else -> response
}
}
.retryWhen{ throwableHandler ->
throwableHandler.flatMap {
when(it) {
is Exception() -> Flowable.error(it)
else -> Flowable.timer(3,TimeUnit.SECONDS)
}
}
}
.timeout(60, TimeUnit.SECONDS)
}
MainClass.kt
usecase.getResult()
.subscribeOn(Schedulers.io())
.observeOn(AndroidSchedulers.mainThread())
.subscribeBy(onError = {Log.d(TAG,"Error")},
onSuccess = {Log.d(TAG,"Next")})
When app run :
If api return NULL, retryWhen() will be invoked then api is called again.
Event not timeout reached and api return Not NUL result -> onSuccess is called. This is correctly processing of retryWhen() operator in rxJava.
My Problem:
If I write some test method (to pretend API Retrofit) in MainClass.kt looks like below:
private fun testPretend(): Single<Animal> {
return Single.just(Animal)
}
MainClass.kt looks like:
testPretend()
.subscribeOn(Schedulers.io())
.observeOn(AndroidSchedulers.mainThread())
.subscribeBy(onError = {Log.d(TAG,"Error")},
onSuccess = {Log.d(TAG,"Next")})
So event retryWhen is invoked , testPretend() method is not called again.
What is the problem here?
And what is difference between Single return by testPrerend() and Retrofit API ?
retrofit observable retrofit2 rx-java2 rx-android
asked Nov 29 '18 at 6:26
miho39miho39
194521
fun get() : Single<Animal>
– miho39
Nov 29 '18 at 6:35
fun getResult(): Single<Animal>
– miho39
Nov 29 '18 at 6:36
Sorry I can not format the description @@
– miho39
Nov 29 '18 at 6:36
add a comment |
API class using Retrofit
class interface TestApi {
@GET("/path/abc/xyz")
fun get(): Single
}
UseCase class
fun getResult(): Single {
return testApi.get()
.map{ response ->
val type = response.type
when(type){
null -> throw Exception()
else -> response
}
}
.retryWhen{ throwableHandler ->
throwableHandler.flatMap {
when(it) {
is Exception() -> Flowable.error(it)
else -> Flowable.timer(3,TimeUnit.SECONDS)
}
}
}
.timeout(60, TimeUnit.SECONDS)
}
MainClass.kt
usecase.getResult()
.subscribeOn(Schedulers.io())
.observeOn(AndroidSchedulers.mainThread())
.subscribeBy(onError = {Log.d(TAG,"Error")},
onSuccess = {Log.d(TAG,"Next")})
When app run :
If api return NULL, retryWhen() will be invoked then api is called again.
Event not timeout reached and api return Not NUL result -> onSuccess is called. This is correctly processing of retryWhen() operator in rxJava.
My Problem:
If I write some test method (to pretend API Retrofit) in MainClass.kt looks like below:
private fun testPretend(): Single<Animal> {
return Single.just(Animal)
}
MainClass.kt looks like:
testPretend()
.subscribeOn(Schedulers.io())
.observeOn(AndroidSchedulers.mainThread())
.subscribeBy(onError = {Log.d(TAG,"Error")},
onSuccess = {Log.d(TAG,"Next")})
So event retryWhen is invoked , testPretend() method is not called again.
What is the problem here?
And what is difference between Single return by testPrerend() and Retrofit API ?
retrofit observable retrofit2 rx-java2 rx-android
asked Nov 29 '18 at 6:26
miho39miho39
194521
API class using Retrofit
class interface TestApi {
@GET("/path/abc/xyz")
fun get(): Single
}
UseCase class
fun getResult(): Single {
return testApi.get()
.map{ response ->
val type = response.type
when(type){
null -> throw Exception()
else -> response
}
}
.retryWhen{ throwableHandler ->
throwableHandler.flatMap {
when(it) {
is Exception() -> Flowable.error(it)
else -> Flowable.timer(3,TimeUnit.SECONDS)
}
}
}
.timeout(60, TimeUnit.SECONDS)
}
MainClass.kt
usecase.getResult()
.subscribeOn(Schedulers.io())
.observeOn(AndroidSchedulers.mainThread())
.subscribeBy(onError = {Log.d(TAG,"Error")},
onSuccess = {Log.d(TAG,"Next")})
When app run :
If api return NULL, retryWhen() will be invoked then api is called again.
Event not timeout reached and api return Not NUL result -> onSuccess is called. This is correctly processing of retryWhen() operator in rxJava.
My Problem:
If I write some test method (to pretend API Retrofit) in MainClass.kt looks like below:
private fun testPretend(): Single<Animal> {
return Single.just(Animal)
}
MainClass.kt looks like:
testPretend()
.subscribeOn(Schedulers.io())
.observeOn(AndroidSchedulers.mainThread())
.subscribeBy(onError = {Log.d(TAG,"Error")},
onSuccess = {Log.d(TAG,"Next")})
So event retryWhen is invoked , testPretend() method is not called again.
What is the problem here?
And what is difference between Single return by testPrerend() and Retrofit API ?
retrofit observable retrofit2 rx-java2 rx-android
retrofit observable retrofit2 rx-java2 rx-android
asked Nov 29 '18 at 6:26
miho39miho39
194521
asked Nov 29 '18 at 6:26
miho39miho39
194521
asked Nov 29 '18 at 6:26
miho39miho39
194521
asked Nov 29 '18 at 6:26
miho39miho39
194521
asked Nov 29 '18 at 6:26
miho39miho39
194521
194521
fun get() : Single<Animal>
– miho39
Nov 29 '18 at 6:35
fun getResult(): Single<Animal>
– miho39
Nov 29 '18 at 6:36
Sorry I can not format the description @@
– miho39
Nov 29 '18 at 6:36
add a comment |
fun get() : Single<Animal>
– miho39
Nov 29 '18 at 6:35
fun getResult(): Single<Animal>
– miho39
Nov 29 '18 at 6:36
Sorry I can not format the description @@
– miho39
Nov 29 '18 at 6:36
fun get() : Single<Animal>
– miho39
Nov 29 '18 at 6:35
fun get() : Single<Animal>
– miho39
Nov 29 '18 at 6:35
fun getResult(): Single<Animal>
– miho39
Nov 29 '18 at 6:36
fun getResult(): Single<Animal>
– miho39
Nov 29 '18 at 6:36
Sorry I can not format the description @@
– miho39
Nov 29 '18 at 6:36
Sorry I can not format the description @@
– miho39
Nov 29 '18 at 6:36
add a comment |
1 Answer
1
active
oldest
votes
The method testPretend() is not called again because the observable that it returned is what is being resubscribed to. If you want the method to be invoked again upon resubscription, you will need to do something like this:
Single.defer( () => testPretend() )
...
.retryWhen( ... )
...;
This will invoke testPretend() upon resubscription.
answered Nov 29 '18 at 14:24
Bob DalgleishBob Dalgleish
6,34222436
Thank you for the answer. Yes ! It works if I use fromCallable instead of just . So can use explain more about just, create or fromCallable operator of Single? Why just operator can not use for this case ?
– miho39
Nov 30 '18 at 5:29
add a comment |
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',
autoActivateHeartbeat: false,
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
});
}
});
Sign up or log in
StackExchange.ready(function () {
StackExchange.helpers.onClickDraftSave('#login-link');
});
Sign up using Google
Sign up using Facebook
Sign up using Email and Password
Post as a guest
Required, but never shown
StackExchange.ready(
function () {
StackExchange.openid.initPostLogin('.new-post-login', 'https%3a%2f%2fstackoverflow.com%2fquestions%2f53533017%2frxandroid-operator-retrywhen-is-invoked-but-does-not-resubscribe%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
The method testPretend() is not called again because the observable that it returned is what is being resubscribed to. If you want the method to be invoked again upon resubscription, you will need to do something like this:
Single.defer( () => testPretend() )
...
.retryWhen( ... )
...;
This will invoke testPretend() upon resubscription.
answered Nov 29 '18 at 14:24
Bob DalgleishBob Dalgleish
6,34222436
Thank you for the answer. Yes ! It works if I use fromCallable instead of just . So can use explain more about just, create or fromCallable operator of Single? Why just operator can not use for this case ?
– miho39
Nov 30 '18 at 5:29
add a comment |
The method testPretend() is not called again because the observable that it returned is what is being resubscribed to. If you want the method to be invoked again upon resubscription, you will need to do something like this:
Single.defer( () => testPretend() )
...
.retryWhen( ... )
...;
This will invoke testPretend() upon resubscription.
answered Nov 29 '18 at 14:24
Bob DalgleishBob Dalgleish
6,34222436
Thank you for the answer. Yes ! It works if I use fromCallable instead of just . So can use explain more about just, create or fromCallable operator of Single? Why just operator can not use for this case ?
– miho39
Nov 30 '18 at 5:29
add a comment |
The method testPretend() is not called again because the observable that it returned is what is being resubscribed to. If you want the method to be invoked again upon resubscription, you will need to do something like this:
Single.defer( () => testPretend() )
...
.retryWhen( ... )
...;
This will invoke testPretend() upon resubscription.
answered Nov 29 '18 at 14:24
Bob DalgleishBob Dalgleish
6,34222436
The method testPretend() is not called again because the observable that it returned is what is being resubscribed to. If you want the method to be invoked again upon resubscription, you will need to do something like this:
Single.defer( () => testPretend() )
...
.retryWhen( ... )
...;
This will invoke testPretend() upon resubscription.
answered Nov 29 '18 at 14:24
Bob DalgleishBob Dalgleish
6,34222436
answered Nov 29 '18 at 14:24
Bob DalgleishBob Dalgleish
6,34222436
answered Nov 29 '18 at 14:24
Bob DalgleishBob Dalgleish
6,34222436
answered Nov 29 '18 at 14:24
Bob DalgleishBob Dalgleish
6,34222436
6,34222436
Thank you for the answer. Yes ! It works if I use fromCallable instead of just . So can use explain more about just, create or fromCallable operator of Single? Why just operator can not use for this case ?
– miho39
Nov 30 '18 at 5:29
add a comment |
Thank you for the answer. Yes ! It works if I use fromCallable instead of just . So can use explain more about just, create or fromCallable operator of Single? Why just operator can not use for this case ?
– miho39
Nov 30 '18 at 5:29
Thank you for the answer. Yes ! It works if I use fromCallable instead of just . So can use explain more about just, create or fromCallable operator of Single? Why just operator can not use for this case ?
– miho39
Nov 30 '18 at 5:29
Thank you for the answer. Yes ! It works if I use fromCallable instead of just . So can use explain more about just, create or fromCallable operator of Single? Why just operator can not use for this case ?
– miho39
Nov 30 '18 at 5:29
add a comment |
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.
Sign up or log in
StackExchange.ready(function () {
StackExchange.helpers.onClickDraftSave('#login-link');
});
Sign up using Google
Sign up using Facebook
Sign up using Email and Password
Post as a guest
Required, but never shown
StackExchange.ready(
function () {
StackExchange.openid.initPostLogin('.new-post-login', 'https%3a%2f%2fstackoverflow.com%2fquestions%2f53533017%2frxandroid-operator-retrywhen-is-invoked-but-does-not-resubscribe%23new-answer', 'question_page');
}
);
Post as a guest
Required, but never shown
Sign up or log in
StackExchange.ready(function () {
StackExchange.helpers.onClickDraftSave('#login-link');
});
Sign up using Google
Sign up using Facebook
Sign up using Email and Password
Post as a guest
Required, but never shown
Sign up or log in
StackExchange.ready(function () {
StackExchange.helpers.onClickDraftSave('#login-link');
});
Sign up using Google
Sign up using Facebook
Sign up using Email and Password
Post as a guest
Required, but never shown
Sign up or log in
StackExchange.ready(function () {
StackExchange.helpers.onClickDraftSave('#login-link');
});
Sign up using Google
Sign up using Facebook
Sign up using Email and Password
Sign up using Google
Sign up using Facebook
Sign up using Email and Password
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
fun get() : Single<Animal>
– miho39
Nov 29 '18 at 6:35
fun getResult(): Single<Animal>
– miho39
Nov 29 '18 at 6:36
Sorry I can not format the description @@
– miho39
Nov 29 '18 at 6:36