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.
