Описание тега reactor
The reactor design pattern is an event handling pattern for handling service requests delivered concurrently to a service handler by one or more inputs. The service handler demultiplexes the incoming requests and dispatches them synchronously to the associated request handlers.
0
ответов
Как сделать условный почтовый индекс с Reactor?
// there are three elements in profileSource // Profile(1, "Aris") // Profile(2, "Bob") // Profile(3, "Cathy") Flux.fromArray(new int[]{1, 3}) .zipWith(profileSource, /* a lambda to match id and profile */ ) .map( /* tuple.t1 is ID, tuple.t2 is Prof…
20 сен '18 в 10:11
1
ответ
Автобан + витое переподключение
У меня есть ряд клиентов, которые должны быть постоянно подключены к моему серверу через ws протокол. По ряду разных причин соединения иногда теряются. Это приемлемо, но когда это произойдет, я бы хотел, чтобы мои клиенты восстановили соединение. В …
19 янв '17 в 15:36
1
ответ
Блок Java CompletableFuture.complete()
У меня проблема при использовании CompletableFuture в Java. У меня есть 2 запроса на выбор, которые заполняются при получении ответов от сервера. В соединительной резьбе (THREAD-1) (использую реактор) я использую: if(hasException) { selectFuture.com…
03 ноя '16 в 03:40
1
ответ
Twisted IRC Bot соединение неоднократно теряется на локальный хост
Я пытаюсь реализовать IRC Bot на локальном сервере. Бот, который я использую, идентичен тому, который можно найти в блоге Эрика Флоренцано. Это упрощенный код (который должен работать) import sys import re from twisted.internet import reactor from t…
01 дек '12 в 00:32
1
ответ
Mono.flatMap не работает во время проверки ответа с помощью MockWebServer
Делая HTTP-вызов с использованием WebClient, из вывода Mono я хочу сделать некоторую логику, для которой я использую метод flatMap. Mono<Response> authResponseMono = webClient.post().syncBody(requestBody) .retrieve() .bodyToMono(Response.class…
19 ноя '18 в 12:15
1
ответ
Операция карты терминала не вызывается в Mono
Вот соответствующий код: Mono<ResponseEntity<String>> res = remoteCall(HttpMethod.POST, issueTokenUrl, GsonConvertor.getInstance().serialize(request)); Mono<IssueToken> it = res.map(this::getIssueToken); Удаленный вызов успешен (ко…
21 окт '18 в 19:18
1
ответ
Reactor 3.x: есть ли оператор для throttleLatest (conflate)?
В rx-java 2.x есть оператор с именем throttleLatest, который объединяет входящие события на основе заданного времени: https://github.com/ReactiveX/RxJava/pull/5979 Есть ли подобный оператор в Reactor 3? Или возможно получить то же поведение, комбини…
01 окт '18 в 17:56
1
ответ
Весна реагирует на процесс больше моно в моно
У меня есть метод, как: public Mono<Double> calculate(OperandDto dto) { Mono<Double> dbResult1Mono = mongoReactRepo.findByMyLogic(dto); Mono<Double> dbResult2Mono = mongoReactRepo.findByMyOtherLogic(dto); // ? Multiply these result…
22 мар '18 в 09:00
0
ответов
Реактор: обнаружение пустого сигнала, чтобы иметь возможность действовать на пустой моно
Есть оператор или какой-то хороший подход для достижения поведения doOnEmpty() с Project Reactor Mono? Я хочу иметь побочные эффекты (логирование) для результата операции. Вот что у меня сейчас: myMono .map(value -> new Wrapped(value)) .defaultIf…
26 фев '19 в 07:27
1
ответ
Spring асинхронный REST с DeferredResult и Reactor
Это лучшая идея, которую я мог бы разработать, чтобы получить асинхронность с Reactor в вызове REST, для удобства: я не удивлен... есть идеи, как это сделать лучше? ( полный код здесь для справки) Интерфейс REST: @RestController public class REST_In…
22 ноя '15 в 12:12
1
ответ
Будет ли Reactor обеспечивать удаленное взаимодействие?
Я пытаюсь выяснить, должны ли мы использовать Akka или Reactor для нашего следующего проекта. Один из наиболее важных вопросов заключается в том, обеспечит ли будущая структура выбора возможность удаленного взаимодействия. Как я увидел, Акка предлаг…
17 авг '13 в 08:20
2
ответа
Реактивный цикл событий в Python
Я пытаюсь построить систему, которая собирает данные из некоторых источников с помощью ввода-вывода (HDD, сеть...) Для этого у меня есть класс (контроллер), который запускает коллекторы. Каждый коллектор представляет собой бесконечный цикл с классич…
18 ноя '14 в 22:37
0
ответов
Каковы некоторые причины, по которым 'proce ssor.callFromThread(func)`не будет работать
Я пытаюсь отладить проблему так, чтобы reactor.callFromThread(func) не буду ничего делать В настоящее время у меня есть функция, которая выполняет операцию выхода, включая закрытие файлов... и т. Д. def exit(self): try: def clean_handler(): exit_han…
17 июн '14 в 21:22
1
ответ
Twisted Reactor не может быть перезапущен - используется асинхронная многопоточность
У меня есть список URL-адресов. Я хочу получать их содержимое асинхронно каждые 10 секунд. urls = [ 'http://www.python.org', 'http://stackru.com', 'http://www.twistedmatrix.com', 'http://www.google.com', 'http://launchpad.net', 'http://github.com', …
05 окт '15 в 22:15
1
ответ
Python Twister Reactor источник времени callLater?
Я понял, что когда я планирую функцию с: reactor.callLater(delay, function) Если во время задержки системная дата изменяется, задержка, установленная в реакторе.callLater, не будет соблюдена. Так, например, если в 15:00:00 я планирую свою функцию на…
20 май '15 в 15:06
0
ответов
Понимание реактора FluxProcessor.wrap(вверх по течению, вниз по течению)
Процессоры (субъекты в RxJava) действуют как издатели и подписчики, так что они могут подписаться на издателя и, кроме того, подписаться так, чтобы они передавали значения, полученные от верхнего подписчика: Publisher | \/ Processor | \/ Subscriber …
10 май '16 в 09:50
1
ответ
Параллельный реактор против реактора
Я сталкивался с некоторыми сетевыми платформами, когда просматривал библиотеку POCO C++. Два из них - реактор и параллельный реактор. Я хотел бы знать, в чем разница между этими двумя рамками. Спасибо...
21 авг '17 в 05:53
1
ответ
Project Reactor с Netty TCP Server - размер байта в 1024 при декодировании сообщений
Мы используем версию Spring Boot 1.2.8.RELEASE которая имеет управляемую зависимость org.projectoreactor.* с версией Reactor 1.1.6.RELEASE, Проблема, с которой я сталкиваюсь, находится внутри моего пользовательского кодека (reactor.io.encoding.Codec…
05 янв '16 в 19:25
0
ответов
Как ограничить количество результатов в ReactiveMongoRepository
Я ищу способ передать ограничение монго-запроса в ReactiveCrudRepository Я попытался добавить "First2" к имени метода, но я все еще получаю все результаты. Что я действительно ищу, так это способ передачи значения limit в метод, передавая его в запр…
24 сен '18 в 16:19
0
ответов
Upstream не отменяется, когда более одного оператора toProcessor()?
Когда я использовал оператор toProcessor() более одного раза, как в следующем фрагменте кода, восходящий Mono не будет отменен. Вопросы: Может ли кто-нибудь объяснить, почему это происходит? Означает ли это, что использование toProcessor более одног…
01 ноя '18 в 09:13