Dear List, I'm trying to revisit this problem now that streams is in a stable state; but I don't quite see how to use MergeLogic to perform this sort merge - is it actually possible and does anyone would have hints toward a working solution?
thanks in advance, best william On Wed, Sep 24, 2014 at 7:28 AM, √iktor Ҡlang <[email protected]> wrote: > +1 > > On Wed, Sep 24, 2014 at 5:07 AM, Endre Varga <[email protected]> > wrote: > >> There will be all kinds of merges available in the future. Akka Streams >> is still a preview so we change stuff all the time. To get to the point >> where we can support pluggable merges we needed the graph API and support >> for n-way fan-in operations first. So stay tuned :) >> >> -Endre >> >> On Wed, Sep 24, 2014 at 1:43 AM, William Le Ferrand <[email protected]> >> wrote: >> >>> It looks like that: >>> https://gist.github.com/williamleferrand/c77133af821d5eb278be (I feel >>> bad looking at it) >>> >>> On Tue, Sep 23, 2014 at 4:38 PM, √iktor Ҡlang <[email protected]> >>> wrote: >>> >>>> Now it is way more clear! :) So you have 2 sorted streams that you want >>>> to merge to be one sorted stream. >>>> Right now I don't think there's a good machinery for doing this, but I >>>> may be misinformed. >>>> What does the solution that you came up with look like? >>>> >>>> >>>> >>>> On Tue, Sep 23, 2014 at 7:29 PM, William Le Ferrand <[email protected] >>>> > wrote: >>>> >>>>> Sorry, the source stream are already sorted (that's what I meant >>>>> earlier by "ordered data"), so you just have to compare the head of your >>>>> two sources to decide which element you want to push in the outbound >>>>> stream >>>>> first. Does it make sense? >>>>> >>>>> On Tue, Sep 23, 2014 at 4:24 PM, √iktor Ҡlang <[email protected]> >>>>> wrote: >>>>> >>>>>> I still don't understand, if we have 2 unbounded streams, how do we >>>>>> sort them without consuming all of them first? >>>>>> >>>>>> On Tue, Sep 23, 2014 at 7:06 PM, William Le Ferrand < >>>>>> [email protected]> wrote: >>>>>> >>>>>>> Victor, >>>>>>> >>>>>>> It would be an unbounded stream of ordered items (potentially as >>>>>>> slow as the slowest source stream) >>>>>>> >>>>>>> On Tue, Sep 23, 2014 at 3:59 PM, √iktor Ҡlang < >>>>>>> [email protected]> wrote: >>>>>>> >>>>>>>> Hi William, >>>>>>>> >>>>>>>> I am not sure I understand the question, given N unbounded streams >>>>>>>> of comparable items, what does the resulting stream look like? >>>>>>>> >>>>>>>> On Tue, Sep 23, 2014 at 1:31 PM, William Le Ferrand < >>>>>>>> [email protected]> wrote: >>>>>>>> >>>>>>>>> Dear List, >>>>>>>>> >>>>>>>>> I've a set of reactive streams that contain ordered data. Is there >>>>>>>>> an easy way to "sort merge" them into a single reactive stream? I >>>>>>>>> couldn't >>>>>>>>> find anything in the documentation nor on the web; I came up with a >>>>>>>>> handmade solution but it looks unnecessary obfuscated >>>>>>>>> >>>>>>>>> Thanks in advance, >>>>>>>>> >>>>>>>>> Best >>>>>>>>> William >>>>>>>>> >>>>>>>>> -- >>>>>>>>> William Le Ferrand >>>>>>>>> >>>>>>>>> Mobile : (+1) (415) 683-1484 >>>>>>>>> Web : http://williamleferrand.github.com/ >>>>>>>>> <http://www.linkedin.com/in/williamleferrand> >>>>>>>>> >>>>>>>>> -- >>>>>>>>> >>>>>>>>>> Read the docs: http://akka.io/docs/ >>>>>>>>> >>>>>>>>>> Check the FAQ: >>>>>>>>> http://doc.akka.io/docs/akka/current/additional/faq.html >>>>>>>>> >>>>>>>>>> Search the archives: >>>>>>>>> https://groups.google.com/group/akka-user >>>>>>>>> --- >>>>>>>>> You received this message because you are subscribed to the Google >>>>>>>>> Groups "Akka User List" group. >>>>>>>>> To unsubscribe from this group and stop receiving emails from it, >>>>>>>>> send an email to [email protected]. >>>>>>>>> To post to this group, send email to [email protected]. >>>>>>>>> Visit this group at http://groups.google.com/group/akka-user. >>>>>>>>> For more options, visit https://groups.google.com/d/optout. >>>>>>>>> >>>>>>>> >>>>>>>> >>>>>>>> >>>>>>>> -- >>>>>>>> Cheers, >>>>>>>> √ >>>>>>>> >>>>>>>> -- >>>>>>>> >>>>>>>>>> Read the docs: http://akka.io/docs/ >>>>>>>> >>>>>>>>>> Check the FAQ: >>>>>>>> http://doc.akka.io/docs/akka/current/additional/faq.html >>>>>>>> >>>>>>>>>> Search the archives: >>>>>>>> https://groups.google.com/group/akka-user >>>>>>>> --- >>>>>>>> You received this message because you are subscribed to the Google >>>>>>>> Groups "Akka User List" group. >>>>>>>> To unsubscribe from this group and stop receiving emails from it, >>>>>>>> send an email to [email protected]. >>>>>>>> To post to this group, send email to [email protected]. >>>>>>>> Visit this group at http://groups.google.com/group/akka-user. >>>>>>>> For more options, visit https://groups.google.com/d/optout. >>>>>>>> >>>>>>> >>>>>>> >>>>>>> >>>>>>> -- >>>>>>> William Le Ferrand >>>>>>> >>>>>>> Mobile : (+1) (415) 683-1484 >>>>>>> Web : http://williamleferrand.github.com/ >>>>>>> <http://www.linkedin.com/in/williamleferrand> >>>>>>> >>>>>>> -- >>>>>>> >>>>>>>>>> Read the docs: http://akka.io/docs/ >>>>>>> >>>>>>>>>> Check the FAQ: >>>>>>> http://doc.akka.io/docs/akka/current/additional/faq.html >>>>>>> >>>>>>>>>> Search the archives: >>>>>>> https://groups.google.com/group/akka-user >>>>>>> --- >>>>>>> You received this message because you are subscribed to the Google >>>>>>> Groups "Akka User List" group. >>>>>>> To unsubscribe from this group and stop receiving emails from it, >>>>>>> send an email to [email protected]. >>>>>>> To post to this group, send email to [email protected]. >>>>>>> Visit this group at http://groups.google.com/group/akka-user. >>>>>>> For more options, visit https://groups.google.com/d/optout. >>>>>>> >>>>>> >>>>>> >>>>>> >>>>>> -- >>>>>> Cheers, >>>>>> √ >>>>>> >>>>>> -- >>>>>> >>>>>>>>>> Read the docs: http://akka.io/docs/ >>>>>> >>>>>>>>>> Check the FAQ: >>>>>> http://doc.akka.io/docs/akka/current/additional/faq.html >>>>>> >>>>>>>>>> Search the archives: >>>>>> https://groups.google.com/group/akka-user >>>>>> --- >>>>>> You received this message because you are subscribed to the Google >>>>>> Groups "Akka User List" group. >>>>>> To unsubscribe from this group and stop receiving emails from it, >>>>>> send an email to [email protected]. >>>>>> To post to this group, send email to [email protected]. >>>>>> Visit this group at http://groups.google.com/group/akka-user. >>>>>> For more options, visit https://groups.google.com/d/optout. >>>>>> >>>>> >>>>> >>>>> >>>>> -- >>>>> William Le Ferrand >>>>> >>>>> Mobile : (+1) (415) 683-1484 >>>>> Web : http://williamleferrand.github.com/ >>>>> <http://www.linkedin.com/in/williamleferrand> >>>>> >>>>> -- >>>>> >>>>>>>>>> Read the docs: http://akka.io/docs/ >>>>> >>>>>>>>>> Check the FAQ: >>>>> http://doc.akka.io/docs/akka/current/additional/faq.html >>>>> >>>>>>>>>> Search the archives: >>>>> https://groups.google.com/group/akka-user >>>>> --- >>>>> You received this message because you are subscribed to the Google >>>>> Groups "Akka User List" group. >>>>> To unsubscribe from this group and stop receiving emails from it, send >>>>> an email to [email protected]. >>>>> To post to this group, send email to [email protected]. >>>>> Visit this group at http://groups.google.com/group/akka-user. >>>>> For more options, visit https://groups.google.com/d/optout. >>>>> >>>> >>>> >>>> >>>> -- >>>> Cheers, >>>> √ >>>> >>>> -- >>>> >>>>>>>>>> Read the docs: http://akka.io/docs/ >>>> >>>>>>>>>> Check the FAQ: >>>> http://doc.akka.io/docs/akka/current/additional/faq.html >>>> >>>>>>>>>> Search the archives: >>>> https://groups.google.com/group/akka-user >>>> --- >>>> You received this message because you are subscribed to the Google >>>> Groups "Akka User List" group. >>>> To unsubscribe from this group and stop receiving emails from it, send >>>> an email to [email protected]. >>>> To post to this group, send email to [email protected]. >>>> Visit this group at http://groups.google.com/group/akka-user. >>>> For more options, visit https://groups.google.com/d/optout. >>>> >>> >>> >>> >>> -- >>> William Le Ferrand >>> >>> Mobile : (+1) (415) 683-1484 >>> Web : http://williamleferrand.github.com/ >>> <http://www.linkedin.com/in/williamleferrand> >>> >>> -- >>> >>>>>>>>>> Read the docs: http://akka.io/docs/ >>> >>>>>>>>>> Check the FAQ: >>> http://doc.akka.io/docs/akka/current/additional/faq.html >>> >>>>>>>>>> Search the archives: >>> https://groups.google.com/group/akka-user >>> --- >>> You received this message because you are subscribed to the Google >>> Groups "Akka User List" group. >>> To unsubscribe from this group and stop receiving emails from it, send >>> an email to [email protected]. >>> To post to this group, send email to [email protected]. >>> Visit this group at http://groups.google.com/group/akka-user. >>> For more options, visit https://groups.google.com/d/optout. >>> >> >> -- >> >>>>>>>>>> Read the docs: http://akka.io/docs/ >> >>>>>>>>>> Check the FAQ: >> http://doc.akka.io/docs/akka/current/additional/faq.html >> >>>>>>>>>> Search the archives: https://groups.google.com/group/akka-user >> --- >> You received this message because you are subscribed to the Google Groups >> "Akka User List" group. >> To unsubscribe from this group and stop receiving emails from it, send an >> email to [email protected]. >> To post to this group, send email to [email protected]. >> Visit this group at http://groups.google.com/group/akka-user. >> For more options, visit https://groups.google.com/d/optout. >> > > > > -- > Cheers, > √ > > -- > >>>>>>>>>> Read the docs: http://akka.io/docs/ > >>>>>>>>>> Check the FAQ: > http://doc.akka.io/docs/akka/current/additional/faq.html > >>>>>>>>>> Search the archives: https://groups.google.com/group/akka-user > --- > You received this message because you are subscribed to the Google Groups > "Akka User List" group. > To unsubscribe from this group and stop receiving emails from it, send an > email to [email protected]. > To post to this group, send email to [email protected]. > Visit this group at http://groups.google.com/group/akka-user. > For more options, visit https://groups.google.com/d/optout. > -- William Le Ferrand Mobile : (+1) (415) 683-1484 Web : http://williamleferrand.github.com/ <http://www.linkedin.com/in/williamleferrand> -- >>>>>>>>>> Read the docs: http://akka.io/docs/ >>>>>>>>>> Check the FAQ: >>>>>>>>>> http://doc.akka.io/docs/akka/current/additional/faq.html >>>>>>>>>> Search the archives: https://groups.google.com/group/akka-user --- You received this message because you are subscribed to the Google Groups "Akka User List" group. To unsubscribe from this group and stop receiving emails from it, send an email to [email protected]. To post to this group, send email to [email protected]. Visit this group at http://groups.google.com/group/akka-user. For more options, visit https://groups.google.com/d/optout.
