These are chat archives for akkadotnet/akka.net
bool AroundReceive(Receive handler, object message)that is invoked for each message. You can use it as a sort of aspect programming in your actors.
runnable.Run(materializer)and then you're disposing materializer immediatelly after
Guys, any examples of using Framing.LengthField(x) method in Tcp.Streaming?
@shersh this essentially tells: get first X bytes of the stream, convert them to the int - this is the length of the next frame. Make sure that the next
ByteString passed will be of provided length before pushing it to the next stage. Then repeat the process for the next frame