Unit testing RxJava code with multiple external calls
Here is some RxJava code that I want to test:
public void triggerCancelOrderJob() {
couchConnector()
.findAbandonedOpenOrders()
.flatMap(results -> results.rows())
.flatMap(
row ->
Observable.just(row)
.subscribeOn(Schedulers.io())
.map(
s -> return s.value())
.flatMap(
orderId -> {
return RxReactiveStreams.toObservable(
serviceTokenCache
.get(OrderApiConstants.SERVICE_TOKEN_CACHE_KEY)
.flatMap(
issueToken -> {
return cancelOrderApiConnector()
.invokeAPI(
RequestInputModel.builder().build(),
RequestInputModel.RequestBodyModel.builder().build());
}));
}))
.subscribe(//additional code)
So what's happening is that I run an async CB query, get an Observable< AsyncN1qlQueryResult >, then for each row I call call two external services one after the another (first call to the serviceTokenCache and second call to the cancelOrderApiConnector). Each row runs in a separate IO thread.
Note: serviceTokenCache.get() and cancelOrderApiConnector().invokeAPI() return a Mono respectively.
I cannot figure out how to test this code. What all components need to be tested? Since each row will run in its separate thread, I cannot wrap my head around how to test such asynchronous code.
java unit-testing mocking rx-java reactive-programming
asked Nov 22 '18 at 6:48
Prashant PandeyPrashant Pandey
430213
add a comment |
Here is some RxJava code that I want to test:
public void triggerCancelOrderJob() {
couchConnector()
.findAbandonedOpenOrders()
.flatMap(results -> results.rows())
.flatMap(
row ->
Observable.just(row)
.subscribeOn(Schedulers.io())
.map(
s -> return s.value())
.flatMap(
orderId -> {
return RxReactiveStreams.toObservable(
serviceTokenCache
.get(OrderApiConstants.SERVICE_TOKEN_CACHE_KEY)
.flatMap(
issueToken -> {
return cancelOrderApiConnector()
.invokeAPI(
RequestInputModel.builder().build(),
RequestInputModel.RequestBodyModel.builder().build());
}));
}))
.subscribe(//additional code)
So what's happening is that I run an async CB query, get an Observable< AsyncN1qlQueryResult >, then for each row I call call two external services one after the another (first call to the serviceTokenCache and second call to the cancelOrderApiConnector). Each row runs in a separate IO thread.
Note: serviceTokenCache.get() and cancelOrderApiConnector().invokeAPI() return a Mono respectively.
I cannot figure out how to test this code. What all components need to be tested? Since each row will run in its separate thread, I cannot wrap my head around how to test such asynchronous code.
java unit-testing mocking rx-java reactive-programming
asked Nov 22 '18 at 6:48
Prashant PandeyPrashant Pandey
430213
Mock the external calls usingMockito
– Niraj Chauhan
Nov 22 '18 at 7:44
Firstly, inject the schedulers instead of usingSchedulers.io(). This will make it much easier to unit test. Secondly, mock or inject the code for the external calls. Also, you using the nestedflatMap()incorrectly or redundantly -- it isn't doing what you think it is doing.
– Bob Dalgleish
Nov 22 '18 at 14:53
add a comment |
Here is some RxJava code that I want to test:
public void triggerCancelOrderJob() {
couchConnector()
.findAbandonedOpenOrders()
.flatMap(results -> results.rows())
.flatMap(
row ->
Observable.just(row)
.subscribeOn(Schedulers.io())
.map(
s -> return s.value())
.flatMap(
orderId -> {
return RxReactiveStreams.toObservable(
serviceTokenCache
.get(OrderApiConstants.SERVICE_TOKEN_CACHE_KEY)
.flatMap(
issueToken -> {
return cancelOrderApiConnector()
.invokeAPI(
RequestInputModel.builder().build(),
RequestInputModel.RequestBodyModel.builder().build());
}));
}))
.subscribe(//additional code)
So what's happening is that I run an async CB query, get an Observable< AsyncN1qlQueryResult >, then for each row I call call two external services one after the another (first call to the serviceTokenCache and second call to the cancelOrderApiConnector). Each row runs in a separate IO thread.
Note: serviceTokenCache.get() and cancelOrderApiConnector().invokeAPI() return a Mono respectively.
I cannot figure out how to test this code. What all components need to be tested? Since each row will run in its separate thread, I cannot wrap my head around how to test such asynchronous code.
java unit-testing mocking rx-java reactive-programming
asked Nov 22 '18 at 6:48
Prashant PandeyPrashant Pandey
430213
Here is some RxJava code that I want to test:
public void triggerCancelOrderJob() {
couchConnector()
.findAbandonedOpenOrders()
.flatMap(results -> results.rows())
.flatMap(
row ->
Observable.just(row)
.subscribeOn(Schedulers.io())
.map(
s -> return s.value())
.flatMap(
orderId -> {
return RxReactiveStreams.toObservable(
serviceTokenCache
.get(OrderApiConstants.SERVICE_TOKEN_CACHE_KEY)
.flatMap(
issueToken -> {
return cancelOrderApiConnector()
.invokeAPI(
RequestInputModel.builder().build(),
RequestInputModel.RequestBodyModel.builder().build());
}));
}))
.subscribe(//additional code)
So what's happening is that I run an async CB query, get an Observable< AsyncN1qlQueryResult >, then for each row I call call two external services one after the another (first call to the serviceTokenCache and second call to the cancelOrderApiConnector). Each row runs in a separate IO thread.
Note: serviceTokenCache.get() and cancelOrderApiConnector().invokeAPI() return a Mono respectively.
I cannot figure out how to test this code. What all components need to be tested? Since each row will run in its separate thread, I cannot wrap my head around how to test such asynchronous code.
java unit-testing mocking rx-java reactive-programming
java unit-testing mocking rx-java reactive-programming
asked Nov 22 '18 at 6:48
Prashant PandeyPrashant Pandey
430213
asked Nov 22 '18 at 6:48
Prashant PandeyPrashant Pandey
430213
asked Nov 22 '18 at 6:48
Prashant PandeyPrashant Pandey
430213
asked Nov 22 '18 at 6:48
Prashant PandeyPrashant Pandey
430213
asked Nov 22 '18 at 6:48
Prashant PandeyPrashant Pandey
430213
430213
Mock the external calls usingMockito
– Niraj Chauhan
Nov 22 '18 at 7:44
Firstly, inject the schedulers instead of usingSchedulers.io(). This will make it much easier to unit test. Secondly, mock or inject the code for the external calls. Also, you using the nestedflatMap()incorrectly or redundantly -- it isn't doing what you think it is doing.
– Bob Dalgleish
Nov 22 '18 at 14:53
add a comment |
Mock the external calls usingMockito
– Niraj Chauhan
Nov 22 '18 at 7:44
Firstly, inject the schedulers instead of usingSchedulers.io(). This will make it much easier to unit test. Secondly, mock or inject the code for the external calls. Also, you using the nestedflatMap()incorrectly or redundantly -- it isn't doing what you think it is doing.
– Bob Dalgleish
Nov 22 '18 at 14:53
Mock the external calls using
Mockito– Niraj Chauhan
Nov 22 '18 at 7:44
Mock the external calls using
Mockito– Niraj Chauhan
Nov 22 '18 at 7:44
Firstly, inject the schedulers instead of using
Schedulers.io(). This will make it much easier to unit test. Secondly, mock or inject the code for the external calls. Also, you using the nested flatMap() incorrectly or redundantly -- it isn't doing what you think it is doing.– Bob Dalgleish
Nov 22 '18 at 14:53
Firstly, inject the schedulers instead of using
Schedulers.io(). This will make it much easier to unit test. Secondly, mock or inject the code for the external calls. Also, you using the nested flatMap() incorrectly or redundantly -- it isn't doing what you think it is doing.– Bob Dalgleish
Nov 22 '18 at 14:53
add a comment |
0
active
oldest
votes
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%2f53425283%2funit-testing-rxjava-code-with-multiple-external-calls%23new-answer', 'question_page');
}
);
Post as a guest
Required, but never shown
0
active
oldest
votes
0
active
oldest
votes
active
oldest
votes
active
oldest
votes
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%2f53425283%2funit-testing-rxjava-code-with-multiple-external-calls%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
Mock the external calls using
Mockito– Niraj Chauhan
Nov 22 '18 at 7:44
Firstly, inject the schedulers instead of using
Schedulers.io(). This will make it much easier to unit test. Secondly, mock or inject the code for the external calls. Also, you using the nestedflatMap()incorrectly or redundantly -- it isn't doing what you think it is doing.– Bob Dalgleish
Nov 22 '18 at 14:53