val withoutSink = source via graphFlows.fold(Fold[NormalRow])(_ via _) val runnableFlow = withoutSink to sink
runnableFlow.run() On Wed, Jul 8, 2015 at 2:35 AM, Allen Nie <[email protected]> wrote: > Hi, > > I'm trying to construct a stream pipeline automatically based on a > list of Flow: > > val graphFlows: mutable.ListBuffer[Flow[NormalRow, NormalRow, Unit]] = > mutable.ListBuffer.empty[Flow[NormalRow, > NormalRow, Unit]] > > > The example given in stream cookbook chapter: > http://doc.akka.io/docs/akka-stream-and-http-experimental/1.0-M4/scala/stream-cookbook.html > only talks about a fixed pool of workers and how to connect it to a > balancer. > > This is what my code looks like right now: > > val g = FlowGraph.closed(sink) { implicit builder: FlowGraph.Builder > => > > sink => > > import FlowGraph.Implicits._ > > graphFlows.foreach { flow => > source ~> flow > } > > } > > > I have no reason to believe this would work, and I don't even know how > to hook this up to a sink after the flow is chained with source. > > Can anyone shed some light on this? > > Sincerely, > Allen Nie > > -- > >>>>>>>>>> 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.
