Правильный способ остановить потоки Акка при условии

Как отправить сообщение в реактивном потоке от подписчика издателю при подключении через веб-сокет

Использовать поток TCP и перенаправить его на другой приемник (с помощью Akka Streams)

Я пытаюсь перенаправить / переслать поток TCP на другой Sink с Akka 2.4.3. Программа должна открыть сокет сервера, прослушать входящие соединения и затем исп...

Akka Flow зависает при выполнении http-запросов через пул соединений

Я использую Akka 2.4.4 и пытаюсь перейти с Apache HttpAsyncClient (безуспешно).Ниже приведена упрощенная версия кода, который я использую в своем проекте.Про...

Custom Supervision.Decider не перехватывает исключение, созданное ActorPublisher

Я строю библиотеку, которая будет использоваться сторонними разработчиками. В одном из моих методов я возвращаюсь

Как использовать Akka Streams SourceQueue с PlayFramework

Я хотел бы использовать SourceQueue для динамического добавления элементов в источник Akka Stream. Контроллеру воспроизведения необходим источник, чтобы имет...

Как реактивные потоки используются в Slick для вставки данных

ВДокументация Слика Примеры использования Reactive Streams представлены только для чтения данных в качестве средства DatabasePublisher. Но что произойдет, ес...

Как ограничить выполнение Akka Stream и отправку одного сообщения только один раз в секунду?

Получите все тело HttpResponse в виде строки с помощью Akka-Streams HTTP

Доступ к базовому ActorRef потока akka Source, созданного Source.actorRef