Akka Streams で skip・take 処理 - なんとなくな Developer のメモ前回の 「Reactor で skip・take 処理」 と同様の処理を Akka Streams を使用し Java 8 で実装してみました。 Akka Streams 1.0 M2 ソースは http://github.com/fits/try_samples/tree/master/blog/20150112/ はじめに Gradle を使ってビルド・実行するため、下記のような build.gradle を用意しました。 build.gradle apply plugin: 'application' repositories { jcenter() } dependencies { compile 'com.typesafe.akka:akka-stream-experimental_2.11:1.0-M2' } mainClassName = 'sample.Sample1' /
