backpressure

3зной

2ответ

Обертка счетчика, которая предварительно предварительно загружает несколько элементов из базового перечислителя

Предположим, что у меня есть IEnumerator<T>, который выполняет справедливую обработку в методе MoveNext(). Код, потребляемый этим перечислителем, не просто потребляется так быстро, как доступны данные

1зной

2ответ

Как я могу «заставить» какое-то противодавление, чтобы избежать множественных исполнений в rxjava?

У меня есть часть кода, работа которого заключается в обновлении локального кеша. Есть два триггера в этом обновлении кэша: При фиксированном интервале При запросе Так вот простой пример того, как я э

3зной

1ответ

Синхронизированная обратная связь с потоками Akka

То, что я пытаюсь достичь, реализует нечто вроде синхронизированной петли обратной связи с потоками akka. Предположим, у вас есть Flow[Int].filter(_ % 5 == 0). Когда вы передаете поток Int-х к этому п

1зной

1ответ

Akka HTTP обратно давят соединения

The documentation говорит, что на Http().bindAndHandle(): нет противодавление не применяется к соединениям источника, т.е. все соединения принимаются на максимальной скорости, которая, в зависимости о

2зной

1ответ

Шина сообщений против Quasar/HTTP для внутренних вызовов Microservice

Я ищу оптимизацию архитектуры микросервиса, которая в настоящее время использует HTTP/REST для внутренней связи между узлами. Одним из вариантов является использование противодавления в сервисах (напр

0зной

1ответ

Как Highland.js реализует противодавление?

Как именно Highland.js реализовать противодавление? Мне это интересно.

4зной

1ответ

Зачем нам нужны операторы публикации и RefCount Rx в этом случае?

Я пытаюсь знакомиться с проблемой реактивной обработки противодавления, в частности, прочитав эту вики: https://github.com/ReactiveX/RxJava/wiki/Backpressure In the buffer paragraph, у нас есть это бо