[akka-user] How to send a message in a reactive stream from the Sink to the Source in a web socket connection

My application has an Akka-Websocket interface. The web socket consists of an actor-subscriber and an actor publisher. The subscriber handles commands, by sending them to a corresponding actor in the actor system. The publisher listens on the event stream and publishes update information back

[akka-user] Re: How to send a message in a reactive stream from the Sink to the Source in a web socket connection

Hello Frederico I have seen your question/topic <https://groups.google.com/forum/#!topic/akka-user/WEZatmiXpZY> and will post the code there (today). have fun! Flavio -- >>>>>>>>>> Read the docs: http://akka.io/docs/ >>>>>>>&g

[akka-user] Re: akka and websockets integration in Java, how to push from server?

question <https://groups.google.com/forum/#!topic/akka-user/CkbaYINPbkU> later. Have fun! Flavio Ps. A starting point to understand steams could be: https://gist.github.com/staltz/868e7e9bc2a7b8c1f754 public class WebSocketApp extends HttpApp { private static final Gson gson

[akka-user] Re: How to send a message in a reactive stream from the Sink to the Source in a web socket connection

Hello After further investigations into this topic I have now one (more or less) working solution (try2) and one further, simpler, but finally not yet working solution (try1)

[akka-user] Re: How to send a message in a reactive stream from the Sink to the Source in a web socket connection

Final solution is as simple as beautiful (and was answered on Stackoverflow ): Flow.fromSinkAndSourceMat(metricsSink, metricsSource, (sinkActor, sourceActor) -> { si