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

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

Как указать неявное значение для akka.stream.Materializer при отправке FakeRequest?

Как динамически добавить источник в существующий график?

Как создать источник, который может получать элементы позже через вызов метода?

Я хотел бы создать

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

Как использовать клиент Akka-HTTP websocket отправить сообщение

Я пытаюсь веб-сокет на стороне клиента, следуя документ наwebSocketClientFlow.Пример кода:

Реализация Akka-Stream медленнее однопоточной

ОБНОВЛЕНИЕ С 2015-10-30по мотивам Ролана Куна Аунзера:Akka Streams использует асинхронную передачу сообщений между субъектами для реализации этапов обработки...

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

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

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

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

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