Вопросы с тегом 'reactive-programming'

Количество результатов: 699

0 голосов
0 ответов
Обработка запросов в RxJava, держа кэш

Я пытаюсь выполнить следующий «трубопровод», используя RxJava (версия 1 на данный момент, но я мог бы обновить до 2): Непрерывно чтения идентификаторов (строки) из р...

0 голосов
2 ответа
Что такое тайм-аут по умолчанию Спросите в Акку?

Что такое значение по умолчанию для тайм-аута Ask в Акку? Все, что необходимо использовать аск метод в Акку является импорт akka.pattern.ask. В Документах, есть приме...

0 голосов
2 ответа
RxJS застежка-молния() оператор не работает, как ожидалось. Он всегда завершается, не вызывая никакого значения

Сценарий: При наличии наблюдаемого с большим количеством элементов, 450+, например, я хочу, чтобы добавить эти элементы к другим наблюдаемому в партиях от 100 элементо...

0 голосов
1 ответ
RX-Android + ViewModel + дооснащения не вызывает OnComplete()

Я не могу получить метод OnComplete() будет вызван после того, все элементы обработаны. Мне нужно сделать для того, чтобы (аль крайней мере) скрыть вид нагрузки. Я нем...

0 голосов
2 ответа
RxJS Ищет что-то вроде «delayUntil»

У меня есть две функции, одна возвращает observableA и один observableB. Я хочу, чтобы сорбент, а также подписки observableB чтобы отложить до observableA завершена (н...

2 голоса
1 ответ
Как транслировать сообщения в Spring Реактивная WebSocket API?

Я разрабатываю простой чат. Мне очень нравится Tomcat на основе пружинного WebSocket API, но есть одна проблема. Tomcat использует модель потоков на основе. Если у мен...

0 голосов
1 ответ
Resteasy jaxrs с использованием io.vertx.reactivex.core.Vertx

Я строю приложение VertX с интерфейсом веб-службы Jax Rs. Я использую следующую зависимость в моем приложении: <dependency> <groupId>org.jbo...

0 голосов
2 ответа
LiveData изменить с помощью функции обратного вызова

Так что я получил эту функцию в хранилище: fun getFeaturedLive() : MutableLiveData<Resource<Prod>> { val res = MutableLiveData<Resource<Prod&gt...

0 голосов
0 ответов
содержание Государственного среди компонентов

Я новичок реагировать. У меня есть несколько вопросов по поводу поддержания состояния между компонентами. У меня есть проблемы с поддержанием состояния. Это может быть...

0 голосов
3 ответа
RxJs combineLatest, кажется, для имитации дополнительного обновления

Хотя я знаю, что упомянутые в этой теме звучит смешно, он чувствует себя более, когда вы смотрите на код. Тем не менее, я потратил несколько часов, пытаясь пройти чере...

1 голос
1 ответ
RxJs: В чем разница между субъектами и наблюдаемой-многоадресной передачей

Я в настоящее время обучение RxJs на пару недель, и я не могу понять, что именно различие между субъектами и многоадресной передачей наблюдаемой. Я нашел много источ...

4 голоса
1 ответ
Как решить «GLog/logging.h» файл не найден

Я начинаю новый проект реагировать родной или при установке модулей При ошибке получать компилирование времени, пожалуйста, помоги мне, как решить эти проблемы.

0 голосов
1 ответ
Spring Webflux - передача данных поток в конечной точке

У меня есть вопрос относительно Spring Webflux. Я хотел создать реактивную конечную точку, потребляющий тип содержимого текста/EVENT-поток. Не производить, но потребля...

2 голоса
1 ответ
Как фильтровать наблюдаемом, что это массив с помощью функции, которая возвращает Наблюдаемые логических значений

Скажем, у меня есть наблюдаемая называется selectedUsers$ что возвращает Observable, что массив в следующем формате. [ { 'userId': 'someId', 'other': 'propert...

0 голосов
1 ответ
От lodash дребезга к угловым 6 реактивным

У меня странный вопрос, и жаль, если это дублирование некоторого ответа (однако я до сих пор не могу найти решение моей проблемы). Дело в том, что я переделываю стары...

1 голос
1 ответ
Несколько веб-клиенты (Spring webflux) для нескольких хостов

В моем приложении, я звоню 4 различных Apis (все на разных хостах). Я хотел бы иметь отдельный пул соединений для каждого хоста и других параметров (например, сохранит...

0 голосов
3 ответа
Вьет потерянная реактивность

Не могу понять, почему это простые вещи, а не реактивным. Похоже, я пропустил основы некоторых Vue в. <template> <div> {{connection_status}} ...

1 голос
0 ответов
Реактор: Детектирование пустого сигнала, чтобы иметь возможность воздействовать на пустом Mono

Есть ли оператор или какой-то хороший подход для достижения doOnEmpty() вида поведения с проектом реактора Mono? Я хочу, чтобы иметь побочные эффекты (протоколировани...

0 голосов
1 ответ
Как превратить горячий наблюдаемой и одного в холодную наблюдаемом

Я пытаюсь сделать RX обертку для NuProcess, библиотеки для асинхронного выполнения внешних процессов. Здесь главный класс - «связь» с процессом. Здесь я прочитал стан...

8 голосов
1 ответ
Mono против CompletableFuture

CompletableFuture выполняет задачи в отдельном потоке (использует нить-пул) и предоставляет функцию обратного вызова. Скажем, у меня есть вызов API в а CompletableFutu...

0 голосов
1 ответ
Не может десериализация экземпляра <Object> из маркеров START_ARRAY - WebClient

Я пишу простой get способ использования WebClient для извлечения информации свойства. Но тогда, я получаю ниже это ответное сообщение об ошибке: { "timestamp": "2...

0 голосов
2 ответа
Почему Flux.fromIterable() возвращение в RestController возвращается в качестве одного из каскадного строки?

У меня есть контроллер Rest, который возвращает Flux&lt;String&gt;, Но когда я пытаюсь собрать, что в список, это один элемент из всех строк сцепленных. как я могу пол...

0 голосов
0 ответов
Репликация данных в реактивном списке с Spring WebFlux, реактивной MongoDB и угловой

Я новичок в Spring WebFlux, и я пытаюсь написать простой клиент, который запрашивает сервер список ид и обновляет его в режиме реального времени. Исходя из того, что я...

0 голосов
0 ответов
Странное поведение сервера Переданные События с WebFlux

Я новичок в Spring WebFlux. По словам других StackOverflow постов я пытаюсь написать простую реактивную конечную точку, каждый второй он должен создать и отправить нов...

1 голос
1 ответ
Сложность использования стрелка-кт Либо, вариант, и RxJava вместе

У меня много трудностей, выясняя хороший способ для координации использования RxJava вместе с стрелкой-кт Either а также Option типы. У меня есть два метода, которые в...

0 голосов
1 ответ
Как перебрать Mono <List <String >> вызова Mono метод возвращающегося

Я пытаюсь достичь следующих в поле ниже метода Получить все автомобили от дилеров X Создать объект-оболочку, которая хранит множество всех автомобилей и друг...

1 голос
1 ответ
RxSwift - Цепной наблюдаемый и свободные

Мне нужно обратиться за помощью к последовательности функций, чтобы получить всю информацию, мне нужно для уведомления. Первый подписываться, который открывает сеанс, ...

0 голосов
0 ответов
это возможно в Java, чтобы создать класс, который имеет все поля, как наблюдаемые?

Я в настоящее время обучение реактивного программирования на Java (для Android). Я Livedata слушать изменения в поле. Но у меня возникли проблемы. Можно ли вызвать с...

0 голосов
1 ответ
Как создать текучий, который завершает как только его последний абонент прекращает подписку

У меня есть случай, когда мне нужно создать реактивный поток, состоящий из нескольких элементов, которые могут быть завершены два различными способами. Цепь, что у м...

3 голоса
2 ответа
группа RxJava отсортированы данные

У меня есть очень большая коллекция данных и исходные данные уже отсортированы по тому, что будет ключом. Например, у меня есть файл CSV и первый столбец будет ключево...

1 голос
2 ответа
RxSwift BehaviorRelay отменить предыдущие вызовы, использовать только самые последние

у меня есть BehaviorRelay установки для хранения массива адресов, а затем я наблюдаю, что BehaviorRelay так что я могу создать MKAnnotation массив, а затем отобразить,...

0 голосов
0 ответов
Совокупные множественные остальные вызовы пружинных загрузок 2

Я новичок в реактивном программировании на Java, и я пытаюсь сделать microservice, что агрегировать звонки от 3 других microservices. Я не могу понять, как справитьс...

2 голоса
1 ответ
Реактор 3-эмиттер/Подписчик параллельный

я новичок в программировании и реактивная есть много вопросов. Я думаю, что это не недостаток примеров и документации это только мое понимание является неправильным. ...

0 голосов
1 ответ
RxJs, не будут отображаться в йот, но консольные работы

Почему выходы отображаются только в одном из элементов (# Пропуск результат или # отчетливый-результат) не оба из них? но если я пытаюсь вывод результата от двух набл...

0 голосов
0 ответов
Pass реактивного() кадра данных в reactiveValues ​​()

Я довольно новый с rshiny приложений, и я пытаюсь создать приложение, которое работает нормально, но когда я пытаюсь добавить участок с щеткой и удалить функциональные...

1 голос
0 ответов
Как проверить шаги модульного тестирования с Spring 5 Reactor WebFlux?

Я мигрирую из императива в реактивном режим, и я с трудом тестированием мои издевается обратным вызовом в реактивном способе. Можно ли в классе обслуживания, например,...

1 голос
1 ответ
rxjs асинхронные обновления Observable

Какой самый лучший способ для обработки асинхронных обновлений в середине наблюдаемого потока. Скажем, есть 3 Наблюдаемые: Obs1 (получает данные от API) -> трубы к O...

0 голосов
0 ответов
Добавление пользовательской папки Реагировать Capacitor сборки

Кто-нибудь знает, как добавить папку в папке реагировать сборки конденсатора? то есть: в папке Src у меня есть обычай включать в папку, содержащий .json файлы, которы...

0 голосов
1 ответ
Mono.subscriberContext() возвращение старого контекста

У меня есть класс PublishContext с контекстом метода() следующим образом: public static Mono&lt;Object&gt; context(){ return Mono.empty().subscriberContext( con...

2 голоса
1 ответ
ВЗАИМОДЕЙСТВУЕТ: Если HTML формы быть контролируемым или неконтролируемым компоненты?

Я имею дилемму, где Где моя форма, государство должно жить. Реагировать Docs упомянуть: Определите каждый компонент, который визуализирует что-то на основе этого ...

1 голос
1 ответ
Многократный REST API вызовов параллельно с использованием RX Наблюдаемыми

Я пытаюсь вызвать REST API параллельно с помощью наблюдаемой. Я столкнулся некоторые проблемы на этом. Я описал проблему здесь. может кто-нибудь помочь мне в этом? Мо...

0 голосов
1 ответ
каковы различия между .net вариациями наблюдателей модели (IObservable и делегацией событий) и когда использовать каждый?

я просто хочу знать, когда использовать каждый и какие преимущества каждого из них я на самом деле трудно понять, почему .net представил IObservable/IObserver после де...

0 голосов
1 ответ
Используйте оператор sampleTime без приставки задержки?

У меня наблюдаемый поток, который излучает последовательность чисел. Каждый излучается значение требует тяжелого обновления пользовательского интерфейса для перемещени...

0 голосов
1 ответ
Spring Реактивная потребляют POST с помощью FLUX или MONO

Как потреблять POST или же PUT с помощью Mono или же Flux от параметра метода. Будем говорить, что я имею EmployeeApi интерфейс, определенный, как показано ниже, где с...

3 голоса
0 ответов
Fetch тела запроса от org.springframework.web.reactive.function.BodyInserter

У меня есть следующий код, где я смог войти заголовки и URL. Но тело метода() возвращает объект типа BodyInserter. В режиме отладки (STS), мы можем увидеть объект запр...

0 голосов
1 ответ
Правильный способ использовать IReactiveDerivedList в качестве пользовательских типов термин фильтра в

У меня есть список корневой строки в ReactiveList&lt;string&gt; private ReactiveList&lt;string&gt; Items { get; set; } и полученный список private IReactiveDerived...

3 голоса
1 ответ
Создание одного наблюдаемого типа на событие и уничтожить на последних отписках

Представьте себе поток сообщений, каждый с соответствующим идентификатором пользователя. Для каждого сообщения, что приходит, получать связанную информацию о пользоват...

0 голосов
0 ответов
Поиск текста с помощью Реактивное программирование на C#

Мне нужна небольшая помощь. Я начинаю работу с приложением, используя реактивное программирование. (Извините, если я задать основной вопрос) У меня есть сетка с данны...

0 голосов
1 ответ
Нужное место для React стороны сервера визуализации вызова API

Мы используем ComponentWillMount() жизненный цикл для вызовов API в реакции 15 на стороне сервера визуализации. Теперь мы будем мигрировать наше приложение реагировать...

1 голос
1 ответ
flatMap() против подписки() в Spring webflux

Я новичок в Spring WebFlux и пытается преобразовать свою весеннюю MVC приложение webflux. Я возвращаю моно Mono из службы: List&lt;Store&gt; stores = new ArrayLi...

1 2 3 4 5 6 7 8 ... 13 14 right