I'm playing around with Akka Stream and I'm trying to figure out its flexibility after materialization.
One way to do so is to use the low level reactive streams API: http://doc.akka.io/api/akka-stream-and-http-experimental/1.0-M3/#akka.stream.scaladsl.PublisherSource
However, you need to define these points to publish or subscribe to. Is there a way to publish or subscribe to an arbitrary materialized flow graph node? This should be possible, since a materialized flow graph is nothing more than a collection of actors.
For example: First, deploy flow graph 1: A ~> B ~> C
Then, deploy flow graph 2 and 3: D ~> B B ~> E