akkaが提供するIOを理解しようとしています。この問題について別の質問を始めました。
akkaIOの使い方の簡単な例
を見つけました。私はそれを再実装して開始しました。なぜセッションの最初のメッセージだけが印刷されるのか疑問に思います。誰かが何をしているのか、代わりに別の人にメッセージを送る方法を説明してもらえますか?state(socket)(Chunk(bytes))
Actor
ActorSystem
編集
アクターは単一の入力を受け取り、それをコンソールに出力するだけで処理することがわかりました。それは私を別の質問に導きます:どうすればアクターに複数の入力を取り、それらを処理させることができますか?パテを介してサーバーに接続し、Enterキーを1回押すと、期待どおりに入力が処理されますが、別の入力行を送信すると、入力のみが保存されます。どこで実行する必要がflatMap
あるので、次の入力行を処理しますか?ケースの中で試してみましたRead(socket, bytes)
が、うまくいきませんでした。