Вопросы по теме 'backpressure'
Соединения Akka HTTP с обратным давлением
В документации сказано, что Http().bindAndHandle() :
к источнику соединений не применяется обратное давление, т. е. все соединения принимаются с максимальной скоростью, что, в зависимости от приложений, может представлять риск отказа в...
955 просмотров
schedule
22.04.2023
Как происходит внутреннее противодавление в RxJava
Я читал несколько документов по противодавлению в RxJava, но я не могу найти подробного объяснения, например, как это происходит внутри библиотеки, все просто резюмируют это, как «производитель» слишком быстрый, а «потребитель» слишком медленный....
381 просмотров
schedule
19.01.2023
Исключение BackPressure в коде RxJava даже после применения надлежащего оператора
Я использую RxJava в своем приложении для Android. Я использую таймер с помощью функции interval(), но получаю исключение Missing Backpressure, хотя я добавил onBackPressureDrop(). Я также добавил onError() к моему подписчику и регистрирую...
686 просмотров
schedule
15.06.2023
ActorPublisher Akka Streams как источник веб-ответа - как работает обратное давление
Я использую актор akka-streams ' ActorPublisher в качестве потоковой передачи данных для каждого соединения Source , отправляемых на входящее соединение WebSocket или HTTP.
ActorPublisher 's контракт заключается в регулярном запросе данных...
192 просмотров
schedule
22.11.2022
Обратное давление для Akka Sharding с настойчивыми актерами
Существует ли модель обратного давления потока Akka или что-то для использования осколков akka с постоянным актером?
Поскольку у меня есть проблема, у меня есть шардинговый кластер akka с постоянными акторами. (используя cassandra в качестве...
369 просмотров
schedule
20.03.2023
Что означает термин противодавление в Rxjava?
Я новичок в RxJava, и мне интересно, что означает "противодействие" .
Означает ли это, что производитель оказывает давление за спиной потребителя?
Или это означает, что потребители оказывают давление на производителей? (Давление в...
6723 просмотров
schedule
10.10.2022
Как сделать обратное давление на уровне запроса akka-http?
В akka-http вы можете:
Установите akka.http.server.max-connections, что предотвратит большее количество подключений. Превышение этого лимита означает, что у клиентов будет время ожидания соединения.
Установите...
989 просмотров
schedule
12.05.2022
Создайте поток с функцией генерации, используя RxJava2
Мне нужно создать собственный Flowable с реализованным противодавлением. Я пытаюсь добиться какой-то подкачки. Это означает, что когда нисходящий поток запрашивает 5 элементов, я «запрашиваю источник данных» для элементов 0–5. Затем, когда...
887 просмотров
schedule
28.07.2022
Имеет ли реализация gRPC на C # обратное давление потоковой передачи?
У меня есть служба gRPC, которая принимает потоковые сообщения от клиента. Клиент отправляет серверу сообщения конечной последовательности с высокой скоростью.
В результате сервер буферизует большое количество сообщений (> 1 ГБ), и использование...
1893 просмотров
schedule
02.01.2023
Какие ресурсы потребляет при переходе Observable на Flowable
Мы переключаем проект с javaRx 1.x на javaRx 2.x. я не могу понять:
Почему я должен оставить Observable в своем проекте, а не везде использовать Flowable.
Если я знаю место, где нет противодавления, нужно ли мне использовать Flowable без...
89 просмотров
schedule
31.12.2022
RxJava 1.x: как имитировать обратное давление в модульном тесте
Учитывая код:
logItemPublisher
.buffer(
loggingProperties.getBufferTimeoutMillis(),
TimeUnit.MILLISECONDS,
loggingProperties.getBufferSize(),
logDispatchScheduler
)...
380 просмотров
schedule
05.03.2023
Akka-streams обратное давление на трансляцию с асинхронной обработкой
Я изо всех сил пытаюсь понять, применяет ли akka-stream обратное давление на источник, когда трансляция с одной ветвью занимает много времени (асинхронно) на графике.
Я попробовал buffer и batch , чтобы увидеть, было ли какое-либо обратное...
718 просмотров
schedule
09.03.2023
Наблюдается несколько потоков в одном планировщике, событие не используется в том же порядке, в котором оно было отправлено.
Я использую событие, используя перенос из разных внешних источников/подписки в разные Flowable. Источник не имеет значения, так как я могу воспроизвести проблему с помощью простого цикла. У меня есть :
Различные FlowableEmitter (достаточно 3...
41 просмотров
schedule
05.01.2023
Проблема обратного давления в rx.net
Я хотел прочитать строки из файла CSV и использовать RX.Net для некоторых преобразований, и я хотел выполнить пакетное обновление и отправлять обновление каждые 250 миллисекунд.
public static IEnumerable<string> ReadCSV(string filePath)
{...
286 просмотров
schedule
04.04.2023
Android : Live Data пропускает значения
Я использую Live Data для публикации состояний из View Model во Fragments, это может привести к частой публикации состояний. Но изменяемые живые данные пропускают начальные значения и берут самое последнее доступное значение.
Существует статья ,...
1971 просмотров
schedule
27.05.2022
ReactiveX Backpressure не работает должным образом
Пытаюсь сделать текучую с противодавлением. Моя идея состоит в том, что новый элемент текучего не будет генерироваться, пока один из текущих элементов не завершит свою обработку. Для этого я использую методы ResourceSubscriber и subscribeWith ()....
260 просмотров
schedule
16.01.2023
Противодавление микронавта
Мы ищем лучший способ ограничить количество одновременных подключений, принимаемых конечной точкой HTTP, доступной с помощью Micronaut 2.0.1. Конечная точка принимает файлы изображений, записывает их на диск и создает эскизы. При слишком большом...
141 просмотров
schedule
19.04.2022
