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!