0

Situation: have a few clients that want to join to server. AkkaStreamServerTCP (actor) manages connections and creates handlers (TcpSession, actor) for each connection. Due GraphStage i can create a really complicated logic for managing data, for example, can add BidiFlow for coding data. But i didn't understand how I can put bunch of data, that i receive from another actor, into stream? For example, in akka.io.Tcp we have Events and Commands, such as Write, Read. But what about streams?

Any help would be appreciated!

enter image description here

Eldar Nezametdinov
  • 1,917
  • 4
  • 21
  • 23

0 Answers0