Akka.Net では、Tcp アクターから TcpStream アクターを派生させることができますか?
を使用して TCP アクターを作成しました
Context.System.Tcp().Tell(new IoTcp.Connect(endPoint));
次に、自分自身をハンドラーとして登録します
Sender.Tell(new IoTcp.Register(Self, true, true));
エンドポイントは、Tcp ストリーム アクターではなく、プレーンなリモート Tcp ソケットを表します。
次に、受信メッセージを購読します
private void OnReceived(IoTcp.Received message)
{
// pass message.Data to a flow to materialize
}
カスタム フレーミング ロジックを定義するフローを介して、Received メッセージをストリームとしてどのように消費できますか?
を使用して接続を作成できますか
var connection = Context.System.TcpStream().OutgoingConnection("",0);