Nice! Thanks a lot! 在 2015年11月19日星期四 UTC-8上午2:02:39，drewhk写道： > > Hi, > > in pseudocode: > > zipWith = ZipWith((b: B, c: C) => BCtoD(b, c)) > sourceA ~> bcast.out1 ~> AtoB ~> zipWith ~> out > bcast.out2 ~> AtoC ~> zipWith > > i.e. you broadcast A, then you calculate B and C in parallel, then you > wait on both (ZipWith) to calculate D. > > -Endre > > On Thu, Nov 19, 2015 at 7:34 AM, Leon Ma <[email protected] <javascript:>> > wrote: > >> Hi, >> >> Assuming I have a Source A which contains elements A1, A2.... >> >> And I'd like to build flow like this: >> >> 1. A1 --> B1, A1 --> C1 For an element A1 , I can call some services >> (time consuming) to transform it into B1 and C1 respectively, and they're >> independent transformation which can run parallel. >> 2. B1 + C1 = D1, I need some merge point to merge B1 and C1 into D1, >> considering D is an composite Source. >> >> >> Btw, this is not like the pancake sample that we can't do B1 + C2, B and >> C must be paired and derived form same A. >> >> How can I model this? Any sample code would be helpful. >> >> >> Thanks >> Leon >> >> >> -- >> >>>>>>>>>> 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] <javascript:>. >> To post to this group, send email to [email protected] >> <javascript:>. >> 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.
