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

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

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

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

akka-stream - Как по-разному трактовать последний элемент потока в потоке / графике

Я пытаюсь реализовать Akka Streams

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

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

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

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

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

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

 только если вы хотите манипулировать сообщениями.

аюсь создать простой прокси для соединений Websocket, используя потоки Play и akka. Транспортный поток выглядит так:

Поэтому я бы сказал, что это максимальное количество элементов, которые можно обрабатывать без регулирования. Обработанный "в то же время" никогда не будет точным определением в потоке :)

def throttle(elements: Int, per: FiniteDuration, maximumBurst: Int, mode: ThrottleMode): Repr[Out]лиmaximumBurst означает количество элементов, которые могут быть обработаны одновременно?