Публикации по теме 'reactive-streams'
Противодавление без потерь в RxJS
Противодавление без потерь в RxJS
Преобразование потоков Node.js в конвейеры RxJS
tl; dr Я придумал способ без потерь справиться с противодавлением в асинхронных итераторах, генераторах и потоках Node.js с помощью RxJS.
Эта статья - мой способ помочь всем людям, которые не могут использовать один набор навыков для множества других ситуаций (например, RxJS и противодавление). RxJS - замечательная потоковая библиотека, и вам не нужно изучать итераторы, генераторы и потоки Node.js..
Использование асинхронных генераторов в качестве пользовательских потоков данных
Одним из самых последних дополнений к ECMAScript / JavaScript являются генераторы асинхронности; они построены на основе обычных генераторов, чтобы добавить асинхронную функциональность. Если вы еще не знакомы с ними, генераторы - это специальные функции, которые могут «возвращать» несколько раз, используя инструкцию yield , подобную этой:
// Generator functions are declared with an asterisk (function*)
function* makeRangeGenerator (start, end) {
let n = 0;
for (let i = start; i..
RxJS - from, catchError, подписаться
Я давно использую RxJS, просмотрел различные видеолекции, прочитал несколько руководств и сообщений в блогах. В большинстве случаев в примерах используются таймеры , интервалы и т. Д. Эти примеры не дали мне никакого понимания, кроме определения поведения оператора или функции. Я просто упустил практическое применение.
В этой серии сообщений в блоге я хотел бы предоставить вам практические примеры из реальной жизни, чтобы вы могли лучше понять силу как RxJS, так и его операторов.
Я..
Вопросы по теме 'reactive-streams'
Реактивные потоки Apache Camel с Bindy - только чтение первой строки
Я пытаюсь использовать реактивные потоки Apache Camel (версия 2.25.3) в сочетании с Spring Boot для чтения большого файла CSV и демаршалинга строк с помощью Bindy. Это работает в том смысле, что приложение запускается и обнаруживает файлы по мере их...
225 просмотров
schedule
29.10.2021
Потоки Akka уменьшаются до меньшего потока
У меня есть упорядоченный поток данных
A A A B B C C C C ... (very long)
И я хочу преобразовать его в поток агрегатов в виде (элемент, количество):
(A, 3) (B, 2) (C, 4)
Какие операторы я могу использовать для этого в Akka Streams?...
391 просмотров
schedule
04.06.2022
Spring WebFlux: метод block() возвращает значение null в Spring Data Reactive MongoDB
Я пытаюсь изучить проект Reactor и столкнулся с проблемой.
@Test
@DisplayName("check that standaloneUser fields are correct")
void validateUserFields() {
userService.save(standaloneUser).subscribe();...
1456 просмотров
schedule
16.07.2022
Обнаружение пустого окна Flux перед публикацией веб-клиента
Что касается моего предыдущего вопроса Разделение сообщения WebClient потокового потока в массивы JSON , которые я использовал;
myFlux
.window(5)
.flatMap(window -> client
.post()
.body(window, myClass.class)
.exchange()...
933 просмотров
schedule
27.07.2022
Потоковый ответ от HTTP-клиента с помощью реактора Spring / Project
Как передать ответ от реактивного HTTP-клиента контроллеру без сохранения всего тела ответа в памяти приложения в любое время?
Практически все примеры проектного реактора-клиента возвращают Mono<T> . Насколько я понимаю, реактивные потоки...
518 просмотров
schedule
31.07.2022
Как правильно вызывать HTTP-клиент Akka для нескольких (10–100 к) запросов?
Я пытаюсь написать инструмент для пакетной загрузки данных с использованием Akka HTTP 2.0-M2. Но я столкнулся с akka.stream.OverflowStrategy$Fail$BufferOverflowException: Exceeded configured max-open-requests value of [32] error.
Я попытался...
6312 просмотров
schedule
17.03.2023
Как реактивные потоки используются в Slick для вставки данных
В документации Slick представлены примеры использования Reactive Streams только для чтения. data как средство DatabasePublisher. Но что происходит, когда вы хотите использовать свою базу данных в качестве приемника и обратного давления в...
2393 просмотров
schedule
15.02.2023
Управляется ли сообщение или событие Reactive Stream?
Я пытаюсь выяснить, управляются ли реактивные потоки сообщениями или событиями. Есть разные версии, в манифесте говорится, что Reactive Streams управляется сообщениями. Но в другой статье говорят только о Событиях. Или, может быть, это оба...
179 просмотров
schedule
20.06.2023
этап пользовательского графа akka stream
У меня есть поток akka из веб-сокета, например поток akka использует веб-сокет и например, построить повторно используемый этап графика ( inlet : поток, FlowShape : добавить дополнительное поле в JSON, указывающее источник, т.е.
{
...,...
442 просмотров
schedule
19.04.2023
Где размещать проверки параметров в реактивных потоках?
Сегодня в офисе мы с коллегами обсуждали важность того, чтобы вычисления выполнялись декларативно внутри реактивного потока, а не жадно, а императивно при вызове метода.
Для пояснения приведу очень наивный, но наглядный пример. Мы сказали, что...
187 просмотров
schedule
22.10.2022
Когда FlatMap будет прослушивать несколько источников одновременно?
В каких ситуациях Flux::flatMap одновременно прослушивает несколько источников (0...бесконечность)?
Во время экспериментов я обнаружил, что когда восходящий поток отправляет сигналы flatMap в потоке thread-upstream-1 , и есть N внутренних...
1380 просмотров
schedule
18.05.2023
Потоки Akka не запускаются, когда в Source большое количество записей
Я пытаюсь написать очень простой вводный пример использования Akka Streams. Я пытаюсь в основном создать поток, который берет диапазон целых чисел в качестве источника и отфильтровывает все целые числа, которые не являются простыми, создавая поток...
210 просмотров
schedule
02.02.2023
Реактивные потоки: как дождаться всех издателей по ключу?
Предположим, у меня есть 3 издателя и 1 процессор. Издатели выпускают элементы в форме {key: <integer>, value: <object>, publisher_id: <string>} .
Издатели выполняют операции ввода-вывода, поэтому:
С одной стороны, я бы...
166 просмотров
schedule
25.07.2023
Ошибка зависимости времени выполнения MongoDB Reactive Streams с Alpakka Mongo Connector ClassNotFoundException
Я пытаюсь интегрировать Alpakka Mongo Connector в приложение, которое сильно зависит от библиотек Akka для потоковой обработки . Приложение также использует Akka HTTP . Я столкнулся с проблемой зависимости во время выполнения. В частности, я...
110 просмотров
schedule
28.12.2022
Как я могу опубликовать материализованный граф потоков Akka Stream или подписаться на него?
Я играю с Akka Stream и пытаюсь понять его гибкость после материализации.
Один из способов сделать это — использовать низкоуровневый API реактивных потоков:...
883 просмотров
schedule
28.01.2024