How to achieve an ordered Observable.merge()
I have to observables that don't complete
val firstObservable = ....
val secondObservable = ...
What I'm trying to achieve is some kind of ordered merge between these two observables, I have tried
Observable.merge(firstObservable, secondObservable)
but this obviously does not guarantee the order of the items being preserved.
What first seemed to work for me it was:
Observable.concatArrayEager(firstObservable, secondObservable)
but since my observables don't complete the secondObservable never gets the chance to emit items. I have also tried
Observable.concatArrayEager(firstObservable.take(1), secondObservable.take(2))
but the problem with this approach is that all the other emissions are ignored. Has anyone any idea how to handle this kind of situation?
I would like to keep receiving items from my observable but also preserve order.
Observable.concatArrayEager(firstObservable, secondObservable)
seemed a good direction for me because it used to run my observables in parallel and performance is also important for me, but I'm not able to make it work and also keep the observables continuously emitting items
If you have any ideas please let me know. Thank you!
android observable rx-java2 edited Nov 21 '18 at 17:41
Sarath Kn
1,613919
asked Nov 21 '18 at 16:51
AdrianAdrian
62
add a comment |
I have to observables that don't complete
val firstObservable = ....
val secondObservable = ...
What I'm trying to achieve is some kind of ordered merge between these two observables, I have tried
Observable.merge(firstObservable, secondObservable)
but this obviously does not guarantee the order of the items being preserved.
What first seemed to work for me it was:
Observable.concatArrayEager(firstObservable, secondObservable)
but since my observables don't complete the secondObservable never gets the chance to emit items. I have also tried
Observable.concatArrayEager(firstObservable.take(1), secondObservable.take(2))
but the problem with this approach is that all the other emissions are ignored. Has anyone any idea how to handle this kind of situation?
I would like to keep receiving items from my observable but also preserve order.
Observable.concatArrayEager(firstObservable, secondObservable)
seemed a good direction for me because it used to run my observables in parallel and performance is also important for me, but I'm not able to make it work and also keep the observables continuously emitting items
If you have any ideas please let me know. Thank you!
android observable rx-java2 edited Nov 21 '18 at 17:41
Sarath Kn
1,613919
asked Nov 21 '18 at 16:51
AdrianAdrian
62
Can you provide an example of such custom logic with this operator?
– Adrian
Nov 21 '18 at 17:09
2
It is quite confusing for me what you want to achieve. I don't understand what is the order you want to preserve if both are infinite streams. If you want to preserve the order in which the items were emitted, that's a merge operation. If you want to put all the emissions of one observable before the other, one of them has to have an end. If given one emission of one observable and one emission of the other observable, you want to decide the order of those two, then you can use a Zip. Please, explain with a concrete example what you want to achieve
– dglozano
Nov 21 '18 at 17:26
add a comment |
I have to observables that don't complete
val firstObservable = ....
val secondObservable = ...
What I'm trying to achieve is some kind of ordered merge between these two observables, I have tried
Observable.merge(firstObservable, secondObservable)
but this obviously does not guarantee the order of the items being preserved.
What first seemed to work for me it was:
Observable.concatArrayEager(firstObservable, secondObservable)
but since my observables don't complete the secondObservable never gets the chance to emit items. I have also tried
Observable.concatArrayEager(firstObservable.take(1), secondObservable.take(2))
but the problem with this approach is that all the other emissions are ignored. Has anyone any idea how to handle this kind of situation?
I would like to keep receiving items from my observable but also preserve order.
Observable.concatArrayEager(firstObservable, secondObservable)
seemed a good direction for me because it used to run my observables in parallel and performance is also important for me, but I'm not able to make it work and also keep the observables continuously emitting items
If you have any ideas please let me know. Thank you!
android observable rx-java2 edited Nov 21 '18 at 17:41
Sarath Kn
1,613919
asked Nov 21 '18 at 16:51
AdrianAdrian
62
I have to observables that don't complete
val firstObservable = ....
val secondObservable = ...
What I'm trying to achieve is some kind of ordered merge between these two observables, I have tried
Observable.merge(firstObservable, secondObservable)
but this obviously does not guarantee the order of the items being preserved.
What first seemed to work for me it was:
Observable.concatArrayEager(firstObservable, secondObservable)
but since my observables don't complete the secondObservable never gets the chance to emit items. I have also tried
Observable.concatArrayEager(firstObservable.take(1), secondObservable.take(2))
but the problem with this approach is that all the other emissions are ignored. Has anyone any idea how to handle this kind of situation?
I would like to keep receiving items from my observable but also preserve order.
Observable.concatArrayEager(firstObservable, secondObservable)
seemed a good direction for me because it used to run my observables in parallel and performance is also important for me, but I'm not able to make it work and also keep the observables continuously emitting items
If you have any ideas please let me know. Thank you!
android observable rx-java2 android observable rx-java2 edited Nov 21 '18 at 17:41
Sarath Kn
1,613919
asked Nov 21 '18 at 16:51
AdrianAdrian
62
edited Nov 21 '18 at 17:41
Sarath Kn
1,613919
asked Nov 21 '18 at 16:51
AdrianAdrian
62
edited Nov 21 '18 at 17:41
Sarath Kn
1,613919
edited Nov 21 '18 at 17:41
Sarath Kn
1,613919
edited Nov 21 '18 at 17:41
Sarath Kn
1,613919
1,613919
asked Nov 21 '18 at 16:51
AdrianAdrian
62
asked Nov 21 '18 at 16:51
AdrianAdrian
62
asked Nov 21 '18 at 16:51
AdrianAdrian
62
62
Can you provide an example of such custom logic with this operator?
– Adrian
Nov 21 '18 at 17:09
2
It is quite confusing for me what you want to achieve. I don't understand what is the order you want to preserve if both are infinite streams. If you want to preserve the order in which the items were emitted, that's a merge operation. If you want to put all the emissions of one observable before the other, one of them has to have an end. If given one emission of one observable and one emission of the other observable, you want to decide the order of those two, then you can use a Zip. Please, explain with a concrete example what you want to achieve
– dglozano
Nov 21 '18 at 17:26
add a comment |
Can you provide an example of such custom logic with this operator?
– Adrian
Nov 21 '18 at 17:09
2
It is quite confusing for me what you want to achieve. I don't understand what is the order you want to preserve if both are infinite streams. If you want to preserve the order in which the items were emitted, that's a merge operation. If you want to put all the emissions of one observable before the other, one of them has to have an end. If given one emission of one observable and one emission of the other observable, you want to decide the order of those two, then you can use a Zip. Please, explain with a concrete example what you want to achieve
– dglozano
Nov 21 '18 at 17:26
Can you provide an example of such custom logic with this operator?
– Adrian
Nov 21 '18 at 17:09
Can you provide an example of such custom logic with this operator?
– Adrian
Nov 21 '18 at 17:09
2
2
It is quite confusing for me what you want to achieve. I don't understand what is the order you want to preserve if both are infinite streams. If you want to preserve the order in which the items were emitted, that's a merge operation. If you want to put all the emissions of one observable before the other, one of them has to have an end. If given one emission of one observable and one emission of the other observable, you want to decide the order of those two, then you can use a Zip. Please, explain with a concrete example what you want to achieve
– dglozano
Nov 21 '18 at 17:26
It is quite confusing for me what you want to achieve. I don't understand what is the order you want to preserve if both are infinite streams. If you want to preserve the order in which the items were emitted, that's a merge operation. If you want to put all the emissions of one observable before the other, one of them has to have an end. If given one emission of one observable and one emission of the other observable, you want to decide the order of those two, then you can use a Zip. Please, explain with a concrete example what you want to achieve
– dglozano
Nov 21 '18 at 17:26
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%2f53416947%2fhow-to-achieve-an-ordered-observable-merge%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%2f53416947%2fhow-to-achieve-an-ordered-observable-merge%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
Can you provide an example of such custom logic with this operator?
– Adrian
Nov 21 '18 at 17:09
2
It is quite confusing for me what you want to achieve. I don't understand what is the order you want to preserve if both are infinite streams. If you want to preserve the order in which the items were emitted, that's a merge operation. If you want to put all the emissions of one observable before the other, one of them has to have an end. If given one emission of one observable and one emission of the other observable, you want to decide the order of those two, then you can use a Zip. Please, explain with a concrete example what you want to achieve
– dglozano
Nov 21 '18 at 17:26