Описание тега reactive-programming

Описание тега Вопросы с тегом
Реактивное программирование - это парадигма программирования, ориентированная на потоки данных и распространение изменений.
1 ответ

Неинтуитивное поведение (для меня) в Reactive.jl

Мой вопрос касается пакета Reactive https://github.com/JuliaLang/Reactive.jl Я прочитал учебник и экспериментирую, изучая подход реактивного программирования. Я пытаюсь следующий код, и он работает как ожидалось: using Reactive x = Signal(100) z = m…
06 июн '16 в 13:28
1 ответ

Вызов метода OnNext () из Observable внутри его производной цепочки

У меня есть такой код: function getTokenFromStorage(cb) { // Get token from storage var token = getToken(); // Feed it to callback function cb(token); } var subject = new Rx.BehaviorSubject(42); var token = subject .flatMap(function() { return Rx.Ob…
17 дек '15 в 16:35
1 ответ

Java JSON streaming, неблокирующий парсер с привязкой POJO

Таким образом, существует activon, который позволяет неблокировать синтаксический анализ JSON. Тогда есть Джексон, который не может делать неблокирование, но может связывать POJO (привязка данных). Есть ли библиотека, которая связывает эти два вмест…
01 авг '17 в 20:38
1 ответ

Использование противодавления для нажатия клавиш в RxJs

Я пытаюсь захватить нажатие клавиши пользователя с помощью RxJS, и для каждого штриха, сгенерировать объект результата, который содержит ключ, продолжительность штриха (время между keyup а также keydown события) и интервал между предыдущими штрихами…
25 мар '16 в 17:31
1 ответ

Комплекс модульных испытаний Наблюдаемые потоки

У меня есть следующая функция, которая (я думаю) возвращает составную наблюдаемую: test(cell) { const observ1 = this.store.select('range').flatMap((val: IRange) => {return this.getCellOEE(val.value)}); const observ2 = this.getCellOEE(cell); retur…
03 май '17 в 17:31
0 ответов

Загрузчик при получении данных в RX

Я довольно новичок в RX, и у меня проблемы с асинхронностью Observables. Я использую RxSwift, но я думаю, что проблема не относится к Swift, поэтому я напишу псевдокод. Вот мой (упрощенный) вариант использования: У меня есть текстовый ввод, и я полу…
09 авг '18 в 14:29
1 ответ

Есть ли "полный" набор функций / операторов для FRP?

Функциональное реактивное программирование - это подход к определению побочных программ чисто функциональным способом. Недавно я использовал rxscala, который является портом порта Java/Scala ReactiveX. Он основан на концепции Observables, которые мо…
15 июн '15 в 18:19
1 ответ

iOS RxSwift 4.2, как реализовать Реактивное расширение CBCentralManager с использованием DelegateProxy?

Я смотрю на этот пример использования реактивных расширений с Core Bluetooth. Тем не менее, он написан на Swift 3.0 и имеет ряд ошибок, работающих в Swift 4.2. Я заинтересован в реализации реактивного расширения CBCentralManager чтобы предоставить м…
10 сен '18 в 22:35
1 ответ

iOS RxSwift, как проверить, если Result == .success?

Меня интересуют только результаты с .success типа, которые приходят из моего запроса. Как я могу установить фильтр, чтобы пропускать только результаты.success из Result<Value> перечисление? public enum Result<Value> { case success(Value)…
02 сен '18 в 13:13
1 ответ

Остановить автоматический рендеринг на экране в React

У меня есть два класса, и от одного я передаю значения другому, у меня есть кнопка в родительском классе, которая должна вызвать функцию, после которой должен отображаться контент Родительский класс такой импорт React из 'реакции'; import ReactDOM f…
28 июл '17 в 07:40
2 ответа

Дебадить без первоначальной задержки

Есть ли в RxJS оператор, который отменяет работу, не задерживая "первое событие в серии", но задерживая (и всегда испуская) "последнее событие в серии"? Что-то вроде этого: ---a----b-c-d-----e-f--- после awesome-debounce(2 dashes) будет выглядеть та…
29 мар '17 в 18:11
1 ответ

Потребление значений одновременно выдается наблюдателем

Я изучаю реактивное программирование с помощью RxJava и хочу одновременно использовать извлеченные значения без блокирования в одном потоке выполнения. Observable .interval(50, TimeUnit.MILLISECONDS) .take(5) .subscribe(new Action1<Long>() { @…
23 янв '15 в 11:47
1 ответ

Плоская карта RxJava: что происходит, когда завершается одно из наблюдаемых результатов?

Я новичок в RxJava, я знаю, что плоские карты предназначены для отображения испускаемого элемента на наблюдаемый. Я также знаю, что на основании документации все излучаемые наблюдаемые объединяются (сглаживаются) в один наблюдаемый поток. Мне было и…
16 апр '17 в 04:36
1 ответ

onCompleted никогда не вызывается

Используя RxSwift, цель моего проекта состоит в том, чтобы каждый раз, когда пользователь вводил город в строке поиска, он вызывал вызов текущей температуры. В настоящее время у меня есть viewModel который содержит var searchingTerm = Variable<St…
01 ноя '16 в 15:58
2 ответа

Как правильно подписаться на Измененную последовательность ReactiveObject?

Еще один вопрос по поводу ReactiveUi. У меня есть ViewModel для редактирования формы. Модель является ReactiveObject. Я хочу включить savecommand только тогда, когда произошли изменения объекта. Моя попытка: var canSaveCommand = this.WhenAnyValue(vm…
10 июл '17 в 20:32
1 ответ

Как получить разницу между двумя наблюдаемыми?

У меня есть obs1 = Observable.range(1, 10) а потом obs2 = Observable.range(5, 10) (как правило, последовательность не будет в порядке возрастания). Я хочу получить разницу между obs2 и obs1, чтобы получить значения (наблюдаемые из них) от obs2, кото…
11 янв '18 в 11:20
1 ответ

Как я могу передать последнее значение потока в обработчик ошибок?

Допустим, у меня есть следующий синхронный код, который требует оригинальных аргументов при обработке ошибок: var input = createInput(123); try { doWork(input); } catch (err) { handleError(input, err); // error handling requires input } Каков наилуч…
01 янв '15 в 03:40
2 ответа

Как работает `valueB`? Всегда возвращает одно и то же значение?

Рассмотрим следующий код: module Main where import Control.Event.Handler import Reactive.Banana import Reactive.Banana.Frameworks main :: IO () main = do (addHandler, fire) <- newAddHandler compile (network addHandler) >>= actuate fire "fir…
19 июн '16 в 00:20
2 ответа

Опрос базы данных с помощью Reactive Extensions

Мне нужно своевременно запрашивать базу данных, чтобы узнать состояние устаревшей системы. Я думал об упаковке запроса вокруг Observable, но я не знаю правильный способ сделать это. По сути, это будет один и тот же запрос каждые 5 секунд. Но боюсь, …
14 ноя '15 в 23:02
2 ответа

В RxJava, как отразить / извлечь ошибку за пределами наблюдаемой?

У нас есть StoreService, который вызывает метод update(key, content), использующий клиент couchbase для получения get ->change_content->replace. В рамках этого процесса мы используем Obserable retryWhen для обработки исключений. В случае, если повто…
23 мар '15 в 14:24