Akka Streamsを利用してTCP通信ができる簡易なコードが書けることを知ったのでメモ。 詳しくは以下のページを参照。 doc.akka.io TCPクライアントのソースコード package io.github.takayukiatkwsk.tcpclient import akka.actor.ActorSystem import akka.str…

Akka Streamsのドキュメントをパラパラと見ていたら Dealing with compressed data streams という項目があって、なんか便利そうだなあと思ってサンプルコードを書いて試してみました。 Streams Cookbook — Akka Documentation package sample import java.n…

Akka Streams ドキュメントを何回かに分けてちらちら見てみる(1)の続き。 バックプレッシャー Back-pressure explained Akka Streamsの利用者はバックプレッシャーをハンドリングするコードを書く必要がない。 ライブラリ側でいい感じに処理してくれる 下流…

最近、業務でAkka Streamsを使った処理に触れることがあって、詳しく知りたいなあと思ったのでドキュメントを読みながら触ってみようと思う。 一度には読み切れないのでいい感じに区切りながら進めていきたい。 Basics and working with Flows — Akka Docume…