Вопросы по теме 'project-reactor'
Пакетный комбинаторный вызов Java Streams
Мой вопрос дня касается комбинаторных операций при создании микросервисов.
Давайте воспользуемся вымышленным сценарием: я хочу построить информационную панель. Панель инструментов состоит из группы людей и их информации (история, обзоры, покупки,...
74 просмотров
schedule
20.07.2022
Spring Асинхронный REST с DeferredResult и Reactor
Это лучшая идея, которую я мог разработать, чтобы получить асинхронность с Reactor в вызове REST для удобства использования: я не удовлетворен ... есть идеи о том, как сделать это лучше?
( полный код здесь для справки )
Интерфейс REST:...
1055 просмотров
schedule
26.11.2022
не может создать https://github.com/reactor/reactor-samples из-за отсутствия доступности зависимостей Gradle
Я клонировал и импортировал проект gradle в eclipse с помощью плагина Gradle.
но я получаю ошибки импорта для всех классов реакторов. Ничего из BUILD.SNAPSHOTS, упомянутых в проекте, не найдено.
./gradlew compileJava: compileJava
ОШИБКА:...
219 просмотров
schedule
03.02.2022
какая связь между реактивным IPC, реактивным потоком ввода-вывода, сетью реактивного потока и реактивным сокетом
Я нашел много репозиториев на Github о реактивном потоке, кажется, есть похожие.
Однако многие репозитории не обновляются несколько месяцев.
Я хочу знать отношения к ним, и я могу сосредоточиться на последних репозиториях.
реактивный-ipc:...
358 просмотров
schedule
16.02.2023
дамп потока реактора lmax
Попытка понять ниже (частично) трассировку стека. Использование реактора весеннего проекта 2.0.4.
У меня есть потоки планировщика задач, которые должны создавать задачи и распределять задачи для рабочих потоков. В этот момент приложение зависает...
591 просмотров
schedule
06.05.2022
одновременное потребление коллекции с использованием реактора
время от времени мне приходится внедрять классическое решение для параллельных производителей и потребителей в рамках проекта, в котором я участвую, и проблема в значительной степени уменьшается за счет наличия некоторой коллекции, которая заполняется...
443 просмотров
schedule
15.04.2023
flux.take (x) или flux.all (..) не ждет всех выбросов
У меня есть flux , который построен из Iterable из 8 элементов ( Flux.fromIterable(..) ). Для каждого излучения потока я хочу вызывать метод асинхронно. Я пробовал разные способы с dispatchOn и publishOn , которые не работали, и в конце концов...
1409 просмотров
schedule
29.04.2023
Как обрабатывать ошибку при выполнении Flux.map ()
Я пытаюсь понять, как обрабатывать ошибки при отображении элементов внутри Flux.
Например, я разбираю строку CSV в одном из своих бизнес-объектов POJO:
myflux.map(stock -> converter.convertHistoricalCSVToStockQuotation(stock));...
22322 просмотров
schedule
05.02.2023
Spring 5 Web Reactive Programming - WebClient ClassCastException при демаршалинге JSON из Spring Reactive Controller, который передает данные
Этот вопрос связан с этим one , в котором я спросил, как передавать данные из Reactive Spring Controller.
Как указал Россен, мы должны использовать text/event-stream для отправки результатов потоковой передачи в качестве событий, отправленных...
2061 просмотров
schedule
08.06.2024
Как мне настроить Reactor-Netty для использования SSL?
Я пытаюсь ознакомиться с Spring Project Reactor ( https://projectreactor.io/ ) и создал небольшое приложение. для выполнения вызовов REST к другой службе через SSL. Я не могу найти способ настроить org.springframework.web.client.reactive.WebClient...
1378 просмотров
schedule
15.08.2022
Идиоматический способ маршрутизации на основе контента с помощью RxJava
Кто-нибудь знает идиоматический способ сделать маршрутизацию на основе контента в RxJava или Reactive Ручей ?
Я вижу, как можно создать реактивный конвейер обработки сообщений, используя стандартный оператор, такой как фильтр карты и...
464 просмотров
schedule
27.06.2023
API-интерфейс Netty HttpServer изменен/отличается от доступных примеров
Создание сервера Netty в сообщении в блоге Арьена Поутсмы и пример видео Джоша Лонга выполняется путем создания экземпляра reactor.ipc.netty.http.HttpServer , а затем вызов метода start или startAndAwait с экземпляром...
837 просмотров
schedule
17.01.2023
Преобразование из Flux в Mono
Как я могу преобразовать Flux с 1 элементом в Mono?
Flux.fromArray(arrayOf(1,2,1,1,1,2))
.distinct()
.take(1)
Как мне сделать это моно (1)?
34756 просмотров
schedule
28.12.2022
Преимущества / недостатки реактивного программирования
Я продолжаю изучать и пробовать реактивный стиль кодирования с использованием Reactor и RxJava. Я понимаю, что реактивное кодирование лучше использует процессор по сравнению с однопоточным исполнением.
Есть ли какое-либо конкретное сравнение между...
24047 просмотров
schedule
06.01.2023
Как кэшировать реактивного издателя, такого как Observable?
Я пытаюсь понять, что произойдет, если я кеширую результат метода, возвращающего холодный Observable? Поток еще не материализовался, так что же на самом деле содержит кеш? Я пытался выяснить это с помощью Hazelcast и Spring Boot, но не смог...
1357 просмотров
schedule
15.07.2023
Конструкция реактора с расчетными значениями
Я пытаюсь понять, как создать дизайн для приложения, которое будет использовать Project Reactor. Скажем, у меня есть электронная таблица, например приложение, в котором значения должны обновляться на основе других значений. Для значений определены...
41 просмотров
schedule
30.09.2022
Flux bufferMillis — Как тестировать?
Я пытаюсь протестировать Flux.bufferMillis с помощью виртуального планировщика, но время от времени это не удается. Ниже приведен код для
StepVerifier.withVirtualTime(new Supplier() {
Flux get() {
return Flux.interval(1...
562 просмотров
schedule
13.06.2022
Не удается получить вызов onNext и onComplete по подписке моно
Я пробовал библиотеку реакторов и не могу понять, почему ниже моно никогда не возвращаются обратно с вызовом onNext или onComplete. Я думаю, что упустил очень тривиальную вещь. Вот пример кода.
MyServiceService service = new MyServiceService();...
1486 просмотров
schedule
14.07.2023
Есть ли у нас эквивалент RxJavaComputationExpressions для Java Spring Reactor?
Я работаю с типом Java Reactor Mono, и я хотел бы иметь очень простую конструкцию, которая дала бы мне «ifThen». Я вижу, что это реализовано для RxJava RxJavaComputationExpressions , но, к сожалению, я привязан к Spring Reactor.
Существует ли...
44 просмотров
schedule
17.05.2024
Как собрать два объекта Flux ‹› в один
Я как бы новичок в реактивном программировании. Побывав на некоторых докладах о реакторе и Spring 5.0, я захотел попробовать эту модель программирования самостоятельно.
У меня есть приложение, которое создает два объекта Flux из разных API с...
2200 просмотров
schedule
18.04.2022
