Публикации по теме '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 просмотров

Потоки 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 просмотров

Обнаружение пустого окна Flux перед публикацией веб-клиента
Что касается моего предыдущего вопроса Разделение сообщения WebClient потокового потока в массивы JSON , которые я использовал; myFlux .window(5) .flatMap(window -> client .post() .body(window, myClass.class) .exchange()...
933 просмотров

Потоковый ответ от HTTP-клиента с помощью реактора Spring / Project
Как передать ответ от реактивного HTTP-клиента контроллеру без сохранения всего тела ответа в памяти приложения в любое время? Практически все примеры проектного реактора-клиента возвращают Mono<T> . Насколько я понимаю, реактивные потоки...
518 просмотров

Как правильно вызывать HTTP-клиент Akka для нескольких (10–100 к) запросов?
Я пытаюсь написать инструмент для пакетной загрузки данных с использованием Akka HTTP 2.0-M2. Но я столкнулся с akka.stream.OverflowStrategy$Fail$BufferOverflowException: Exceeded configured max-open-requests value of [32] error. Я попытался...
6312 просмотров

Как реактивные потоки используются в Slick для вставки данных
В документации Slick представлены примеры использования Reactive Streams только для чтения. data как средство DatabasePublisher. Но что происходит, когда вы хотите использовать свою базу данных в качестве приемника и обратного давления в...
2393 просмотров

Управляется ли сообщение или событие Reactive Stream?
Я пытаюсь выяснить, управляются ли реактивные потоки сообщениями или событиями. Есть разные версии, в манифесте говорится, что Reactive Streams управляется сообщениями. Но в другой статье говорят только о Событиях. Или, может быть, это оба...
179 просмотров

этап пользовательского графа akka stream
У меня есть поток akka из веб-сокета, например поток akka использует веб-сокет и например, построить повторно используемый этап графика ( inlet : поток, FlowShape : добавить дополнительное поле в JSON, указывающее источник, т.е. { ...,...
442 просмотров
schedule 19.04.2023

Где размещать проверки параметров в реактивных потоках?
Сегодня в офисе мы с коллегами обсуждали важность того, чтобы вычисления выполнялись декларативно внутри реактивного потока, а не жадно, а императивно при вызове метода. Для пояснения приведу очень наивный, но наглядный пример. Мы сказали, что...
187 просмотров

Когда FlatMap будет прослушивать несколько источников одновременно?
В каких ситуациях Flux::flatMap одновременно прослушивает несколько источников (0...бесконечность)? Во время экспериментов я обнаружил, что когда восходящий поток отправляет сигналы flatMap в потоке thread-upstream-1 , и есть N внутренних...
1380 просмотров

Потоки Akka не запускаются, когда в Source большое количество записей
Я пытаюсь написать очень простой вводный пример использования Akka Streams. Я пытаюсь в основном создать поток, который берет диапазон целых чисел в качестве источника и отфильтровывает все целые числа, которые не являются простыми, создавая поток...
210 просмотров
schedule 02.02.2023

Реактивные потоки: как дождаться всех издателей по ключу?
Предположим, у меня есть 3 издателя и 1 процессор. Издатели выпускают элементы в форме {key: <integer>, value: <object>, publisher_id: <string>} . Издатели выполняют операции ввода-вывода, поэтому: С одной стороны, я бы...
166 просмотров

Ошибка зависимости времени выполнения 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