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

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

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

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

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

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

 были предоставлены для таких случаев, когда мы знаем и полагаемся на конечную точку HTTP.

я есть топология akka-streams, где я делаю вызов POST, используя akka-http. Я получаю следующее сообщение об ошибке при отправке запроса на незащищенный сервер (с самозаверяющими сертификатами). Это внутренний сервер, так что я в порядке с точки ...

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

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

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

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

Почему цикл потоков Akka не заканчивается на этом графике?

Я хотел бы создать график, который повторяется n раз, прежде чем погрузиться. Я только что создал этот образец, который соответствует моим требованиям, но не...

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

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

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