1. Обзор
В этой статье мы рассмотрим библиотеку akka-streams
, созданную поверх фреймворка актеров Akka, которая соответствует манифесту реактивных потоков . Akka Streams API позволяет нам легко составлять потоки преобразования данных из независимых шагов.
Более того, вся обработка выполняется реактивным, неблокирующим и асинхронным способом.
2. Зависимости Maven
Для начала нам нужно добавить библиотеки akka-stream
и akka-stream-testkit
в наш pom.xml: