In Akka.Net can we derive TcpStream actor from Tcp actor?

117 Views Asked by At

In Akka.Net can we derive TcpStream actor from Tcp actor ?

I created a Tcp actor using

Context.System.Tcp().Tell(new IoTcp.Connect(endPoint));

Then I register my self as the handler

Sender.Tell(new IoTcp.Register(Self, true, true));

The endpoint represent a plain remote Tcp socket and not a Tcp Stream actor.

Then I subscribe to Received message

private void OnReceived(IoTcp.Received message)
{
    // pass message.Data to a flow to materialize
}

How can consume the Received message as a stream via a Flow that will define a custom framing logic ?

Can I create the connection using

var connection = Context.System.TcpStream().OutgoingConnection("",0);
0

There are 0 best solutions below