[akka-user] Fold a large websocket stream message

Hi. I can't manage to fold a big message that is coming over websockets. The future just never complete. Reproduce: val flow: Flow[Message, Message, NotUsed] = Flow.fromSinkAndSource( Sink.foreach { case TextMessage.Streamed(stream) => val f = stream.limit(1

[akka-user] Akka Streams / Play pattern

I want to build a play application fetching different API's, persisting the processed results and stream the results via WebSockets to web clients. I have N actors for N API's in the main controller who are injected by AkkaGuice. Then I have N GraphStages that are in fact responsible for the

[akka-user] Connection retry for TCP stream.

Hi, I'm using tcp for outgoing connection in akka streams. Tcp().outgoingConnection(...) if the target connection drops you can see something like this in debug logs [DEBUG] [05/23/2017 14:08:41.968] [default-akka.actor.default-dispatcher-5] [akka://default/system/IO-TCP/selectors/$a/0] Closin

[akka-user] Best practice to combine akka-http and akka-stream flows

Hi @ all This question is a duplication of this http://stackoverflow.com/questions/37659421/what-is-the-best-way-to-combine-akka-http-flow-in-a-scala-stream-flow stack overflow questions. I would like to speak about best practices to combine akka-stream and akka-http flows. Ivan -- >