backpressure

2зной

1ответ

Как обрабатывать RxJS поток n элементов одновременно и как только элемент сделан, автозаполнение снова возвращается в n?

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

1зной

1ответ

Обращение с противодавлением без отбрасывания элементов или сериализация в RxJava

Короче говоря, есть ли решение для решения противодавления в RxJava, не прибегая к отбрасыванию элементов, сериализации или неограниченной буферизации? Рассмотрите следующую задачу в качестве примера

0зной

2ответ

RxJava - Входы клавиатуры с обратным давлением?

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

3зной

1ответ

Способы поддержания противодавления в потоках Akka с участием нескольких JVM

Мне известно, что с Akka 2.4.16 не существует «удаленной» реализации реактивных потоков. Спецификация фокусируется на потоке, запущенном на одной JVM. Однако, рассматривая прецедент для использования

10зной

2ответ

Как сжимать запрос на запись в cassandra при работе с «executeAsync»?

Я использую драйвер datastax java 3.1.0 для подключения к кластеру cassandra, а моя кластерная версия cassandra - 2.0.10. Я пишу асинхронно с консистенцией QUORUM. private final ExecutorService execut

1зной

2ответ

RxJava: Как реализовать медленного потребителя с буфером и быстрым потребителем в тот же источник?

Во время игры с различными сценариями противодавления я реализовал случай, когда один абонент медленный с буфером, а другой потребляет все, что бросается на него. Это использовало Scala и Akka Streams