第2回Reactive System Meetup in 西新宿 #reactive_shinjuku
Rx実装のRS、Akka実装のRS、オンメモリーストリームベース?のRS、をつなぐコード例 #reactive_shinjuku
2016-02-02 19:40:44Collectionは要素タイプ一個、Akka streamはsourceと宛先?のタイプ二つ #reactive_shinjuku
2016-02-02 19:42:53Sink に入ってきたストリームの先頭を取り出した結果は Future[_](単一値)になると。それはそうだな。 #reactive_shinjuku
2016-02-02 19:44:36Akka HTTPは、OSの送受信バッファー見て、"source"からの入力を制御 #reactive_shinjuku
2016-02-02 19:46:25tcp が os の外に出てるのが気になるけど、普通は os 内ですよね。きっと。 os と書いているところはきっと socket? #reactive_shinjuku
2016-02-02 19:51:52#reactive_shinjuku publisherが無数のセンサーだとしたら、publisher >>>> subscriber になるのかな
2016-02-02 19:53:23request(n) は tcp でいうところの window update ですね #reactive_shinjuku
2016-02-02 19:54:30back pressure制御プロトコルは、業界標準揃えないと相互運用できない、→Reactive Streamの動機 #reactive_shinjuku
2016-02-02 19:55:50Source とかの Mat 型引数は「ユーザが中間値を任意に取り出せるようにするための仕組み」だったのかー。 #reactive_shinjuku
2016-02-02 19:58:11NotUsed出来た、というのこれかな。 出来立てホヤホヤっぽい。 github.com/akka/akka/issu… #reactive_shinjuku
2016-02-02 20:01:41Not yet released -> まだ発売されていない、は Google 先生が犯人かーw #reactive_shinjuku
2016-02-02 20:05:02