0
ответов

Как сбросить BehaviorSubject

У меня есть BehaviorSubject, который я хотел бы сбросить - я имею в виду, что хочу, чтобы последнее значение не было доступно, как если бы оно было только что создано. Я не вижу API для этого, но я полагаю ...
вопрос задан: 17 July 2019 13:16
0
ответов

Вопрос о Spring Webflux: тип возвращаемого значения ResponseEntity < Mono < Foo > > против Mono < ResponseEntity < Foo > > в типе возврата контроллера, следуйте за Flux

Здравствуйте, Spring Webflux разработчики! У меня вопрос к сообществу. Скажите, пожалуйста, в чем разница между ResponseEntity < Mono < Foo>> против Mono < ...
вопрос задан: 20 March 2019 17:52
0
ответов

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

У меня есть бесконечная наблюдаемая, сгенерированная из периодической выборки перечислимого: приватного статического IObservable < Runjob > GetRunjobObservable (IEnumerable < Runjob > runjobs) {var ...
вопрос задан: 7 March 2019 21:40
0
ответов

Репликация данных в реактивном списке с помощью Spring WebFlux, Reactive MongoDB и Angular

Я новичок в Spring WebFlux и пытаюсь написать простой клиент, который запрашивает у сервера список идентификаторов и обновляет его в режиме реального времени. Основываясь на том, что я нашел здесь на stackoverflow и вообще на ...
вопрос задан: 24 February 2019 16:16
0
ответов

Как включить & ldquo; подсказку для цепочки методов & rdquo; в IntelliJ?

Я использую JDK 8 и использую реактивное программирование (весенний webflux). Я хочу знать, как включить «подсказку метода show show» в IntelliJ?
вопрос задан: 18 January 2019 16:56
0
ответов

Встроенная функция для глобального тайм-аута на Flowable

Читая документы об операторе тайм-аута, была ссылка на веб-сайт introtorx.com, который объясняет доступные операции тайм-аута. Второй пример в этом документе указывает, что есть оператор ...
вопрос задан: 17 January 2019 17:20
0
ответов

Robolectric реактивная блокировка First () иногда зависает

Этот тест выглядит нормально и работает нормально. Тем не менее, иногда это занимает навсегда метод blockingFirst (). @Test fun test_getScenarioModel () {doReturn (MockDownloader ({File ("abc.zip")})) ....
вопрос задан: 17 January 2019 05:27
0
ответов

Механизм противодавления в Spring Web-Flux

Я начинающий в Spring Web-Flux. Я написал контроллер следующим образом: @RestController открытый класс FirstController {@GetMapping ("/ first") public Mono getAllTweets () {...
вопрос задан: 9 September 2018 13:40
0
ответов

Реализация реактивного программирования / функций на C #

Недавно я читал о дизайне игровых движков и в конце концов наткнулся на следующее: Что такое (функциональное) реактивное программирование? Мне было интересно, как именно реализовать этот пример ...
вопрос задан: 23 May 2017 12:32
0
ответов

RxJava 2.x: я должен использовать Flowable или Single / Completable?

Я разрабатываю приложение для Android с использованием чистой архитектуры и перевожу его на RxJava 2.x. Я должен сделать несколько сетевых запросов к сервису мыла, поэтому я определил интерфейс API в модуле домена: ...
вопрос задан: 1 March 2017 10:17
0
ответов

Haskell: FRP Reactive Parsec?

Есть ли (или есть) возможно ли иметь) реактивный Parsec (или любой другой чисто функциональный парсер) в Haskell? Проще говоря, я хочу кормить синтаксический анализатор char за char и получать результаты столько, сколько я накормил ...
вопрос задан: 20 February 2017 18:33
0
ответов

Возможно ли использовать Observable.Buffer для чего-то другого, кроме времени?

Я искал примеры использования Observable.Buffer в rx, но не смог найти ничего более существенного, чем стандартная временная буферизация. Кажется, есть перегрузка, чтобы указать "...
вопрос задан: 18 February 2016 17:48
0
ответов

Сравнение реактивных сред Java [закрыто]

Я вижу много фреймворков / библиотек, которые утверждают, что они могут помочь в создании реактивных приложений в Java, таких как: Akka, Vert.x, RxJava, Reactor, QBit и т. Д. У них, похоже, разные подходы, функции, ...
вопрос задан: 12 November 2015 12:38
0
ответов

В чем разница между flatmap и switchmap в RxJava?

Определение документа switchx в rxjava довольно расплывчато, и оно ссылается на ту же страницу, что и flatmap. В чем разница между двумя операторами?
вопрос задан: 27 January 2015 16:51
0
ответов

В чем разница между onComplete и flatMap of Future?

Я пишу Scala-приложение с использованием драйвера ReactiveMongo. Методы, которые обращаются к БД, всегда возвращают Future [T]. Следующие части кода эквивалентны? (С onComplete) val результаты: ...
вопрос задан: 17 October 2014 20:18
0
ответов

RxJS :Рекурсивный список наблюдаемых и один наблюдатель

У меня возникли проблемы с рекурсивной цепочкой наблюдаемых. Я работаю с RxJS, который в настоящее время находится в версии 1.0.10621 и содержит большинство основных функций Rx в сочетании с Rx...
вопрос задан: 2 February 2013 16:50
0
ответов

Обработка событий, зависящая от состояния -, с обновлениями состояния

Я хочу использовать FRP (т. е. реактивный банан 0.6.0.0 )для моего проекта (фронт GDB/MI -конец ). Но у меня проблемы с объявлением сети событий. Есть команды из графического интерфейса и есть стоп-события из...
вопрос задан: 3 August 2012 09:01
0
ответов

Реализация zipE ::Событие t a -> Событие t b -> Событие t (a,b)

Я новичок в реактивном банане и FRP в целом, поэтому прошу прощения, если я упустил что-то очевидное. Для моего проекта (интерфейс GDB/MI -конец )я использую реактивный банан (версии 0.6.0.0 )как для графического интерфейса, так и для...
вопрос задан: 31 July 2012 14:44
0
ответов

Разница во времени в функции реактивного (смысла )в Ямпе

В данный момент я изучаю Haskell и Yampa, и у меня есть вопрос о функции реактивации. реактивировать ::IO a --init -> (Bool -> IO (DTime, Maybe a))--смысл -> (Буль -&...
вопрос задан: 4 July 2012 17:11
0
ответов

reactive-banana throttling events

Я хотел бы реализовать определенный тип регулирования событий в reactive-banana. Это должно работать таким образом, чтобы событие не пропускалось, если оно прибыло менее чем за дельта секунд от последнего события, которое...
вопрос задан: 4 June 2012 21:46
0
ответов

Как удалить повторяющиеся события в reactive-banana

В reactive-banana у меня есть поток событий, который выдает серию чисел, некоторые из которых повторяются несколько раз подряд (меня не волнует все дубликаты, только последовательные дубликаты). Как может...
вопрос задан: 3 April 2012 15:20
0
ответов

Рекомендуемое чтение/учебники для понимания библиотеки FRP reactive-banana [закрыто]

Меня интересует библиотека FRP (Functional Reactive Programming) reactive-banana haskell. Что бы вы рекомендовали прочитать новичку, чтобы понять теорию, лежащую в основе reactive-banana? Как я понимаю, ...
вопрос задан: 9 February 2012 11:56
0
ответов

Исключение между потоками при использовании газа RX

Я получаю недопустимый доступ между потоками. При использовании RX Throttle Вот мой код: yObs.SubscribeOnDispatcher () .DistinctUntilChanged () .Throttle (TimeSpan ....
вопрос задан: 7 January 2012 02:22
0
ответов

reactive-banana: Событие срабатывания, содержащее самое актуальное значение поведения

Предположим, у меня есть триггер события, который я хочу делать две вещи при увольнении. Во-первых, я хочу обновить значение некоторого поведения. Во-вторых, если выполняются другие условия, я хочу, чтобы он запускал другое событие ...
вопрос задан: 26 December 2011 10:17
0
ответов

Я правильно использую реактивный банан?

Вот пример программы FRP на Haskell, использующей библиотеку реактивного банана. Я только начинаю разбираться в Haskell, и особенно Я понял, что означает FRP. Я бы действительно ...
вопрос задан: 26 December 2011 10:16
0
ответов

Может ли reactive-banana обрабатывать циклы в сети?

У нас есть код вроде этого: guiState :: Discrete GuiState guiState = stepperD (GuiState []) $ union (mkGuiState <$> changes model) evtAutoLayout evtAutoLayout :: Event GuiState ...
вопрос задан: 26 December 2011 10:16
0
ответов

Ввод пользовательского интерфейса с помощью reactive-banana-wx

Как вы получаете содержимое элементов пользовательского интерфейса при использовании reactive-banana? Event0 возвращает событие типа Event (), которое имеет тип единицы вместо типа элемента управления. event1 принимает событие ...
вопрос задан: 26 December 2011 10:15
0
ответов

Поведение в реактивном банане

Простите, я только начинаю изучать реактивный банан и FRP. Автор реактивного банана сделал этот пример по моему предложению, в котором он создает счетчик, который можно увеличивать и ...
вопрос задан: 26 December 2011 10:15
0
ответов

reactive-banana: как создать AddHandler?

В настоящее время я пытаюсь познакомиться с FRP с помощью reactive-banana Генриха Апфельмуса, который кажется довольно хорошо документированной и простой библиотекой по сравнению с другими те, на которые я смотрел. Однако я ...
вопрос задан: 26 December 2011 10:14
0
ответов

Где применить поведение (и другие типы) в FRP

Я работаю над программой, использующей реактивный банан, и мне интересно, как структурировать свои типы с помощью основные строительные блоки FRP. Например, вот упрощенный пример из моей реальной программы: скажем, мой ...
вопрос задан: 21 December 2011 18:14