Hey all. Im starting to figure out the graph DSL and I got curious about something and I am not sure it is possible. In the graph below, I have a Source.queue setup and it is working out great to add new elements to programmatically later.
Now, what I am curious about is if I can somehow offer new elements to the graph (say from user input, compared to the normal cron add) and get there materialized value without completing the graph. Example situation, user input causes 5 elements to get dropped into the graph, and I want to get the 5 corresponding values from the input out the end without affecting the continuously added cron elements. It seems like http://doc.akka.io/docs/akka/current/scala/stream/stream-graphs.html#Accessing_the_materialized_value_inside_the_Graph might be close to what I am thinking of, but I can't quite figure out if\how it applies. private val alwaysOnFlow = { val parallelLevel = 5 Flow.fromGraph(GraphDSL.create() { implicit builder => import GraphDSL.Implicits._ val dispatcher = builder.add(Balance[S3Time](parallelLevel)) val merger = builder.add(Merge[ArchiveResult](parallelLevel)) for (i <- 0 until parallelLevel) { val bcast = builder.add(Broadcast[S3Time](2)) val zip = builder.add(Zip[LogSet, LogSet]) dispatcher.out(i) ~> bcast ~> imposterFlow ~> zip.in0 bcast ~> archiveFlow ~> zip.in1 zip.out ~> resultsFlow ~> merger.in(i) } FlowShape(dispatcher.in, merger.out) }) } val alwaysOnGraph = Source.queue[S3Time](50, OverflowStrategy.fail) .map { time => info(s"Starting on ${time.toString}") time } .via(alwaysOnFlow) .to(Sink.foreach { res => info(s"Finished processing ${res.minute}") }) -- >>>>>>>>>> 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 https://groups.google.com/group/akka-user. For more options, visit https://groups.google.com/d/optout.
