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 <endre.va...@typesafe.com> 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 akka-user+unsubscr...@googlegroups.com. >> To post to this group, send email to akka-user@googlegroups.com. >> 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 akka-user+unsubscr...@googlegroups.com. To post to this group, send email to akka-user@googlegroups.com. Visit this group at http://groups.google.com/group/akka-user. For more options, visit https://groups.google.com/d/optout.
