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.
