Вопросы по теме 'backpressure'
Преобразование кода RxJS v4 в v5, обработка очереди с вытягиванием
---abcde-----f-------gh-----i----> //Events
У меня есть «рабочая очередь», за которой я хочу наблюдать / подписываться. Это массив командных объектов для обработки. Новые элементы работы обычно поступают пачками, и их необходимо...
179 просмотров
schedule
17.11.2021
Противодавление в Кафке
У меня есть ситуация в Kafka, где производитель публикует сообщения с гораздо большей скоростью, чем скорость потребления потребителем. Мне нужно реализовать реализацию обратного давления в кафке для дальнейшего использования и обработки....
10998 просмотров
schedule
19.02.2022
Как справиться с противодавлением с помощью облачных функций Google
Есть ли способ управлять параллелизмом выполнения, как это делает AWS Lambda, с помощью облачных функций Google? ( https://docs.aws.amazon.com/lambda/latest/dg/concurrent-executions.html )
Я намерен разработать функцию, которая потребляет файл...
1973 просмотров
schedule
01.03.2022
Как дросселировать запрос записи в кассандру при работе с executeAsync?
Я использую драйвер Java Datastax 3.1.0 для подключения к кластеру cassandra, а моя версия кластера cassandra - 2.0.10. Я пишу асинхронно с КВОРУМНОЙ последовательностью.
private final ExecutorService executorService =...
2881 просмотров
schedule
21.05.2022
Предотвращение противодавления с помощью горячих наблюдаемых
Я использую библиотеку Android ReactiveLocation для получения регулярных обновлений местоположения. Я хочу продолжать получать обновления местоположения, даже если в моем приложении они не используются, чтобы у меня всегда была актуальная...
291 просмотров
schedule
01.06.2022
Как я могу заставить какое-то обратное давление избежать многократного выполнения в rxjava?
У меня есть фрагмент кода, работа которого заключается в обновлении локального кеша. Есть два триггера для этого обновления кеша:
Через фиксированный интервал
По запросу
Итак, вот базовый пример того, как я это сделал....
474 просмотров
schedule
23.07.2022
Как обрабатывать поток RxJS n элементов за раз, и после того, как элемент будет выполнен, снова автоматически заполнить n?
У меня есть поток событий, и я хотел бы вызвать функцию, которая возвращает обещание для каждого из этих событий, проблема в том, что эта функция очень дорогая, поэтому я хотел бы обрабатывать не более n событий за раз.
Эта диаграмма гальки,...
586 просмотров
schedule
11.08.2022
Противодействие RxJava и количество обращений к производителю
Я пытаюсь создать бесконечную прокрутку в своем приложении для Android, используя обратное давление в rx Java. Я хочу, чтобы он вызывал внешнюю службу только запрошенное количество раз (после вызова request(1) ). Но после использования плоской...
833 просмотров
schedule
04.04.2023
Java8 Stream или Reactive / Observer для запросов к базе данных
Я переосмысливаю поведение нашего приложения Spring MVC: лучше ли вытащить (поток Java8) данные из базы данных или позволить базе данных протолкнуть (реактивный / наблюдаемый) данные и используйте противодавление, чтобы контролировать количество....
607 просмотров
schedule
11.10.2022
Как пропустить слишком частые события мыши в RxJS 5 (бета)?
Я использую RxJS 5 (beta10) в проекте . Большинство моих событий происходит с помощью мыши или сенсорного перетаскивания, и мне нужно будет услышать только последнее.
т. е. как мне сделать поток с потерями в RxJS5?
Запуск демонстраций на...
324 просмотров
schedule
22.10.2022
RxJava2 Наблюдаемое противодавление
недавно я понял, что не понимаю, как работает RxJava2 противодавление.
Я провел небольшой тест и ожидаю, что он завершится с ошибкой MissingBackpressureException :
@Test
public void testBackpressureWillFail() {...
1122 просмотров
schedule
20.11.2022
Как создать поток Akka с противодавлением и контролем
Мне нужно создать функцию со следующим интерфейсом:
import akka.kafka.scaladsl.Consumer.Control
object ItemConversionFlow {
def build(config: StreamConfig): Flow[Item, OtherItem, Control] = {
// Implementation goes here
}
Моя проблема в...
564 просмотров
schedule
17.04.2023
Подстановочные знаки MQTT, обратное давление и QOS
Это более общий вопрос, однако он может решаться по-разному в разных клиентах или версиях протокола или, возможно, даже в версиях сервера.
Итак, я говорю о подписке QOS уровня 2. В этом случае пакеты обрабатываются по порядку. А раз есть протокол...
144 просмотров
schedule
19.12.2022
Можно ли заставить обработчик событий ждать, пока не будет выполнен асинхронный/промис-код?
Я использую отличную библиотеку Papa Parse в режиме nodejs для потоковой передачи большого (500 МБ) CSV-файла с более чем 1 миллионом строк в API с медленным сохранением, который может принимать только один запрос за раз. API постоянства основан на...
202 просмотров
schedule
06.02.2023
Наблюдаемая поддерживающая реактивная тяга
Некоторое время я боролся с тем, что я считаю довольно простым вопросом.
У меня есть Flowable , который извлекает набор элементов из сети и отправляет их.
Flowable
.create(new FlowableOnSubscribe<Item>() {
@Override...
486 просмотров
schedule
20.03.2024
WebRTC DataChannel поток/управление/противодавление
RTCDataChannel API не обеспечивает никакого потока/управления или противодавления. Значит ли это, что отправитель теоретически может привести к сбою браузера получателя? По моему мнению, браузер (Chrome, Firefox и т. д. все используют SCTP под...
787 просмотров
schedule
01.05.2024
