3
ответа
Действительно ли возможно не определить переменную в ColdFusion?
Действительно ли возможно не определить переменную в ColdFusion? Например, что-то вроде этого: <cfset myVar = "lsajflksd"/> <cfoutput> <p> myVar Определяется? #IsDefined("myVar") # </p>...
вопрос задан: 9 July 2009 16:58
2
ответа
Spring Flux и аннотация Async
У меня есть приложение Spring Flux, где в какой-то момент мне нужно выполнить тяжелую задачу в фоновом режиме, вызывающей стороне (HTTP-запрос) не нужно ждать, пока эта задача завершится. Без реактора ...
вопрос задан: 18 March 2019 17:37
2
ответа
Разница между будущим и моно
В реактивном программировании (Java) чем отличается Future < T > и (Project Reactor) Mono < T & gt ;? Оба, кажется, средства для доступа к результату асинхронного вычисления в ...
вопрос задан: 17 January 2019 15:51
1
ответ
Reactor Scheduler с анонимным потоком
Я тестирую, как работает реактор, создал такой код, который очень похож на то, что можно найти в документации реактора. import org.junit.Test; import org.junit.runner.RunWith; импорт орг ....
вопрос задан: 20 January 2019 12:35
1
ответ
Конечная точка потока из бесконечного потока Java
У меня есть проблема при обработке потока, который построен из конструкции Stream.generate. Поток Java извлекает некоторые данные из удаленного источника, поэтому я реализовал собственного поставщика, который имеет ...
вопрос задан: 17 January 2019 16:11
1
ответ
Как манипулировать объектами, поступающими из Flux < Object > со значением, полученным из метода, испускающего Mono < Items > неблокирующим способом?
Я пытаюсь манипулировать моими объектами, полученными из Flux, с данными, полученными из Mono, где методы, излучающие Flux объекта и Mono элементов, являются разными вызовами API. Проблема в том, что я ...
вопрос задан: 17 January 2019 13:32
1
ответ
RabbitMQ + Reactor, отправляющий ACK после передачи сообщения?
Я пытаюсь выяснить, является ли Project-Reactor приемлемым вариантом для моего варианта использования. Мне нужна высокая согласованность в моем приложении, я хочу: Получить сообщение от RabbitMQ Выполнить некоторые манипуляции / ...
вопрос задан: 17 January 2019 12:05
1
ответ
Реактор, как повторить шаг n раз, если условие выполнено
Пожалуйста, помогите мне с реактором. Мне нужно проверить одно условие не более n раз и вернуть окончательный результат после того, как я обнаружил, что реактор имеет дополнительный модуль реактора https: //projectreactor.io/docs/extra / ...
вопрос задан: 16 January 2019 15:17
1
ответ
Преобразование асинхронного кода NodeJS в Spring Project Reactor
Ниже приведен код NodeJS: // req и соответственно являются http-запросом, объектами ответа var uri = req.getURI () var pageView = new PageView (uri) var token = req.token if (token) {UserRepository.findByToken (.. ,
вопрос задан: 15 January 2019 18:49
1
ответ
Почему Spring Boot имеет две разные реализации ReactiveX?
Spring Boot имеет две разные зависимости, каждая из которых реализует один и тот же API: Project Reactor и RxJava 2. Вы можете проверить зависимости при весенней загрузке здесь. Так почему дублирование? Есть ли ...
вопрос задан: 15 January 2019 17:01
1
ответ
Как написать этот простой код в реактивном режиме?
Я новичок в проектном реакторе, и у меня есть некоторые трудности с поиском чистого решения для следующего варианта использования. Мой прецедент: я хочу сохранить новый объект в базе данных. Если объект уже находится в ...
вопрос задан: 13 July 2018 16:39
0
ответов
Реактор: скачивайте n изображений параллельно, и отказ одного не должен влиять на остальные
У меня есть случай, когда я хочу получить пути к изображениям (через n вызовов REST). Я хочу, чтобы эти вызовы выполнялись параллельно, и отказ одного не должен влиять на остальные. Это то, что я пытался, но ...
вопрос задан: 29 March 2019 16:45
0
ответов
Слияние источников горячего потока
В Spring Boot 2 с Reactor я пытаюсь объединить два горячих источника Flux. Однако слияние только когда-либо сообщает о первом из двух параметров потока в слиянии. Как мне получить слияние с ...
вопрос задан: 24 March 2019 20:04
0
ответов
Как охотно объединить два Flux?
Флюс & л; Длинные > flux1 = Flux. < Long > create (fluxSink -> {for (long i = 0; i < 20; i ++) {fluxSink.next (i);}}) .filter (...
вопрос задан: 3 March 2019 10:09
0
ответов
Бесконечный поток и массовая запись в базу данных
У меня есть бесконечный поток (от kafka, использующего реактор-kafka) событий, которые я пытаюсь записать пакетами в базу данных, прежде чем перейти к фактической обработке событий. Моя проблема состоит в том, чтобы заставить это работать ...
вопрос задан: 26 February 2019 18:31
0
ответов
Как вызвать блок реактивного потока в WebFilter в проекте Spring WebFlux (Netty)?
У меня есть случай, когда я должен вызвать block () при сохранении пользователя в перехватчике запросов (WebFilter) внутри webfilter перед передачей на конечную точку контроллера. Это потому, что веб-фильтр должен ...
вопрос задан: 19 January 2019 15:11
0
ответов
(S) FTP реактивный (не блокирующий) Java-клиент
Мне нужно получить файл с сервера sftp, обработать его содержимое и вернуться в мое приложение spring-boot-webflux. Кто-нибудь знает любую реактивную / неблокирующую (ые) реализацию клиента ftp в java?
вопрос задан: 17 January 2019 10:36
0
ответов
В проектном реакторе или потоках Акки, в чем концептуальная разница между потребителем и подписчиком?
Понятия приемника и подписчика кажутся мне похожими. Кроме того, я не вижу, чтобы концепция стока была явно определена в спецификации реактивных потоков.
вопрос задан: 9 January 2018 06:27
0
ответов
Сравнение реактивных сред Java [закрыто]
Я вижу много фреймворков / библиотек, которые утверждают, что они могут помочь в создании реактивных приложений в Java, таких как: Akka, Vert.x, RxJava, Reactor, QBit и т. Д. У них, похоже, разные подходы, функции, ...
вопрос задан: 12 November 2015 12:38