Posts

Showing posts with the label actors

akka.stream with TCP as input

Image
In recent post  You are evicted!  I was planning to use akka.net streams solution to solve memory pressure problem. Today I have a solution that I will be testing.  Mainly I used an example from akka.net  manual  pages. As I was stuck on the flow (it is a bidirectional flow, where every byte received can have a response to the sender) I asked on the akka.net discord server  for help as I was stuck in one of the stages, and my code was not compiling.  The TCP flow is very specific as it needs to start with ByteStream and finish with same, as what ever is on the end of the flow is sent directly to the other connected side. The flow has stages listed below: Framing - that splits incoming stuff in chunks by delimiter (new line in our case, but can be a series of bytes as well) Then we are converting it to string Grouping (this is a key for the solution as sending one line over http is a killer) Final stage is the place where it will be send over http, but ...