Thank you Endre! Yes, I have seen that example. In my use case, workers are also partial graphs and I will use builder.add to import the flow as many times as I need and let you know if that did the trick. If I found any other problem, I will simplify my use case so I can just use Flows.
2015-03-03 14:03 GMT+00:00 Endre Varga <[email protected]>: > Btw, have you looked at the actual cookbook sample? > > > http://doc.akka.io/docs/akka-stream-and-http-experimental/1.0-M4/scala/stream-cookbook.html#Balancing_jobs_to_a_fixed_pool_of_workers > > On Tue, Mar 3, 2015 at 2:56 PM, Endre Varga <[email protected]> > wrote: > >> Hi Luis, >> >> It should not stuck but throw, but this will not work: >> >> >>> broadcast.out(i) ~> worker ~> merge.in(i) >>> >> >> You imported worker once, you cannot use it N times. You can either use >> builder.add to add as many times as you need (the parametric import you >> used only matters if you want to expose the materialized value of the >> imported element), but since your worker is a Flow, why don't just accept >> it as a Flow instead of Graph[FlowShape[A, B], Unit]? >> >> It is interesting why it hangs though instead of throwing an exception. >> >> -Endre >> >> >> >>> >>> >> >>> With nrOfWorkers > 1, the creation of this partial graph get stuck after >>> the first iteration. Am I missing something? I was expecting this to create >>> as many workers as desired. >>> >>> Regards, >>> >>> Luis >>> >>> -- >>> >>>>>>>>>> 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. > -- >>>>>>>>>> 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.
