Re: [akka-user] [Akka Streams] Cyclical Flows or Passing Result of Sink to Source

2015-04-27 Thread Konrad Malawski
Hi Oliver, Have you read the section of our docs about cyclic graphs and deadlocks? http://doc.akka.io/docs/akka-stream-and-http-experimental/1.0-M2/scala/stream-graphs.html#Graph_cycles__liveness_and_deadlocks Because akka streams (all reactive streams implementations) are purely demand driven,

[akka-user] [Akka Streams] Cyclical Flows or Passing Result of Sink to Source

2015-04-16 Thread Oliver Winks
Hi, I would like to create a simple flow that consists of a Source (ActorPublisher), several Flows and a Sink (ActorSubscriber) like this: ActorPublisher ~ Flow1 ~ Flow2 ~ ~ FlowN ~ ActorSubscriber However, I would like to connect the Sink (ActorSubscriber) and Source (ActorPublisher) so