RxJava parallel emit once









up vote
0
down vote

favorite












i try to get an array of flowable get executed in parallel with FlowableFromArray



and emit the FlowableFromArray when all flowables are done.



But I'm missing the method to emit on last/latest.



I could only manage to make it work to emit onNext @see below



 val results = FlowableFromArray(flowableArray).parallel()
.runOn(Schedulers.io())
.sequential()
.zipWith(r, BiFunction t1: Flowable<String>, t2: Int
->
t1
.subscribeOn(Schedulers.io())
.map i -> parseYoutubeTrack(i)
.observeOn(AndroidSchedulers.mainThread())
.subscribe next -> TLog.i(TAG, "_NEXT_ $next.videoId")

)
.subscribe()









share|improve this question





















  • This makes no sense; you go parallel to then go back to sequential, then you subscribe in the zip handler. And also what is r?
    – akarnokd
    Nov 11 at 10:32










  • Made it work like so return FlowableFromArray(flowableArray) .parallel() .runOn(Schedulers.computation()) .map f -> parseYoutubeTrack(f.blockingFirst()) .sequential() .blockingLatest().toMutableList()
    – Plagueis
    Nov 18 at 17:05















up vote
0
down vote

favorite












i try to get an array of flowable get executed in parallel with FlowableFromArray



and emit the FlowableFromArray when all flowables are done.



But I'm missing the method to emit on last/latest.



I could only manage to make it work to emit onNext @see below



 val results = FlowableFromArray(flowableArray).parallel()
.runOn(Schedulers.io())
.sequential()
.zipWith(r, BiFunction t1: Flowable<String>, t2: Int
->
t1
.subscribeOn(Schedulers.io())
.map i -> parseYoutubeTrack(i)
.observeOn(AndroidSchedulers.mainThread())
.subscribe next -> TLog.i(TAG, "_NEXT_ $next.videoId")

)
.subscribe()









share|improve this question





















  • This makes no sense; you go parallel to then go back to sequential, then you subscribe in the zip handler. And also what is r?
    – akarnokd
    Nov 11 at 10:32










  • Made it work like so return FlowableFromArray(flowableArray) .parallel() .runOn(Schedulers.computation()) .map f -> parseYoutubeTrack(f.blockingFirst()) .sequential() .blockingLatest().toMutableList()
    – Plagueis
    Nov 18 at 17:05













up vote
0
down vote

favorite









up vote
0
down vote

favorite











i try to get an array of flowable get executed in parallel with FlowableFromArray



and emit the FlowableFromArray when all flowables are done.



But I'm missing the method to emit on last/latest.



I could only manage to make it work to emit onNext @see below



 val results = FlowableFromArray(flowableArray).parallel()
.runOn(Schedulers.io())
.sequential()
.zipWith(r, BiFunction t1: Flowable<String>, t2: Int
->
t1
.subscribeOn(Schedulers.io())
.map i -> parseYoutubeTrack(i)
.observeOn(AndroidSchedulers.mainThread())
.subscribe next -> TLog.i(TAG, "_NEXT_ $next.videoId")

)
.subscribe()









share|improve this question













i try to get an array of flowable get executed in parallel with FlowableFromArray



and emit the FlowableFromArray when all flowables are done.



But I'm missing the method to emit on last/latest.



I could only manage to make it work to emit onNext @see below



 val results = FlowableFromArray(flowableArray).parallel()
.runOn(Schedulers.io())
.sequential()
.zipWith(r, BiFunction t1: Flowable<String>, t2: Int
->
t1
.subscribeOn(Schedulers.io())
.map i -> parseYoutubeTrack(i)
.observeOn(AndroidSchedulers.mainThread())
.subscribe next -> TLog.i(TAG, "_NEXT_ $next.videoId")

)
.subscribe()






android rx-java rx-java2






share|improve this question













share|improve this question











share|improve this question




share|improve this question










asked Nov 10 at 21:07









Plagueis

63




63











  • This makes no sense; you go parallel to then go back to sequential, then you subscribe in the zip handler. And also what is r?
    – akarnokd
    Nov 11 at 10:32










  • Made it work like so return FlowableFromArray(flowableArray) .parallel() .runOn(Schedulers.computation()) .map f -> parseYoutubeTrack(f.blockingFirst()) .sequential() .blockingLatest().toMutableList()
    – Plagueis
    Nov 18 at 17:05

















  • This makes no sense; you go parallel to then go back to sequential, then you subscribe in the zip handler. And also what is r?
    – akarnokd
    Nov 11 at 10:32










  • Made it work like so return FlowableFromArray(flowableArray) .parallel() .runOn(Schedulers.computation()) .map f -> parseYoutubeTrack(f.blockingFirst()) .sequential() .blockingLatest().toMutableList()
    – Plagueis
    Nov 18 at 17:05
















This makes no sense; you go parallel to then go back to sequential, then you subscribe in the zip handler. And also what is r?
– akarnokd
Nov 11 at 10:32




This makes no sense; you go parallel to then go back to sequential, then you subscribe in the zip handler. And also what is r?
– akarnokd
Nov 11 at 10:32












Made it work like so return FlowableFromArray(flowableArray) .parallel() .runOn(Schedulers.computation()) .map f -> parseYoutubeTrack(f.blockingFirst()) .sequential() .blockingLatest().toMutableList()
– Plagueis
Nov 18 at 17:05





Made it work like so return FlowableFromArray(flowableArray) .parallel() .runOn(Schedulers.computation()) .map f -> parseYoutubeTrack(f.blockingFirst()) .sequential() .blockingLatest().toMutableList()
– Plagueis
Nov 18 at 17:05


















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',
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%2f53243415%2frxjava-parallel-emit-once%23new-answer', 'question_page');

);

Post as a guest















Required, but never shown






























active

oldest

votes













active

oldest

votes









active

oldest

votes






active

oldest

votes















 

draft saved


draft discarded















































 


draft saved


draft discarded














StackExchange.ready(
function ()
StackExchange.openid.initPostLogin('.new-post-login', 'https%3a%2f%2fstackoverflow.com%2fquestions%2f53243415%2frxjava-parallel-emit-once%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







這個網誌中的熱門文章

How to read a connectionString WITH PROVIDER in .NET Core?

Node.js Script on GitHub Pages or Amazon S3

Museum of Modern and Contemporary Art of Trento and Rovereto