こんにちは。前回、Actorからの応答を受信できないか試したところ空の結果が返ってきた・・ という結果だったのですが、これでは実際使いにくい、と調べてみたところ、案の定応答を受信する仕組みは存在しました。akka.patterns.askをインポートした上で ? …

こんにちは。今回はAkka Actorに対して送信したメッセージを受信する方法の確認をしてみます。 1. そのまま返り値は返る？ まず、receiveメソッドの結果返り値を返すように修正し、 呼び出し側でメッセージを送った際に返り値をキャストするようにしてみます…

こんにちは。内容的にScalaの復習も兼ねていますがまぁお気になさらず。前回とりあえず最低限動作するものを作成しました。 今回はActorに対してパラメータを渡す方法と、 初期化処理／終了時処理をどう記述するかを確認してみます。Actorのソースを見ると、…

こんにちは。前回でAkka-Streamsのソースを確認していましたが、 そもそものScalaとAkka自体に対する前提知識が不足しているため、 見事にはまってしまった感じでした＾＾；なので、何度かScalaを用いたAkkaの小さなアプリを作成し、 そこから広げていこうと…

こんにちは。前回に引き続き、Akka StreamsのコンポーネントがReactive Streamsで 定義されたコンポーネントのどれに対応しているかを見ていきます。・・・と思ったのですが、 Akka Streamsをまともに読んでも範囲が広すぎるため、 Akka Streamsの利用サンプ…