6
ответов
Что такое (функциональное) реактивное программирование?
Я прочитал статью в Википедии о реактивном программировании. Я также прочитал небольшую статью о функционально-реактивном программировании. Описания довольно абстрактны. Что делает функционал реактивным ...
вопрос задан: 9 March 2017 17:37
5
ответов
Реактивные расширения (Rx) + MVVM =?
Один из основных примеров, используемых для объяснения питания Реактивных Расширений (Rx), комбинирует существующие события от нажатия мыши в новое представление 'события', которое перетаскивают дельты во время мыши: var mouseMoves = от...
вопрос задан: 11 February 2010 10:36
4
ответа
Что такое LINQ для событий a.k.a RX Framework?
Что такое LINQ для событий a.k.a RX Framework или Reactive Extensions в .NET 4.0 (но также доступны в виде версий с резервным копированием)? Другими словами, для чего все эти вещи в System.Reactive.dll?
вопрос задан: 11 February 2010 10:25
3
ответа
Реактивная Платформа (RX), доступный для использования в Моно уже?
Поиском, но единственной вещью, которую я нашел, был http://evain.net/blog/articles/2009/07/30/rebasing-system-reactive-to-the-net-clr, который я взялся за работу, но такое чувство, что должен быть более простой путь...
вопрос задан: 26 April 2010 09:05
3
ответа
101 пример Rx
Править: Спасибо за ссылку на Wiki я уже думаю что с тех пор ее запущенный там, ее более легкое идти туда для проверки его. Однако вопрос здесь также хорош, таким образом, люди, которые не являются вокруг...
вопрос задан: 26 April 2010 09:05
3
ответа
Rx в.Net 3.5, не Асинхронном?
Я играю с Rx в.Net3.5SP1 и пробую 101 Образец Rx. Я пробую первый образец (Запустите - Код Выполнения Асинхронно), но это, кажется, на самом деле не работает асинхронно. Например...
вопрос задан: 26 April 2010 09:04
3
ответа
Примеры полезных или non-trival двойных интерфейсов
Недавно у Erik Meijer и других есть шоу, как IObservable/IObserver является двойным из IEnumerable/IEnumerator. То, что они являются двойными, означает, что любая операция в одном интерфейсе допустима на другом...
вопрос задан: 11 February 2010 10:30
3
ответа
Преимущества.NET Rx по классическим событиям?
.NET 4,0 беты 2 представила интерфейсы IObserver и IObservable. Каковы преимущества по сравнению с классическими событиями.NET? Разве это не решает ту же проблему?
вопрос задан: 11 February 2010 10:18
2
ответа
RxJS takeUntil не отписывается
Я хочу отписаться в декларативном стиле с оператором takeUntil. Но это в принципе не работает. Я все равно вижу вывод консоли. const unsubscribe = new Subject (); функция printFoo () {...
вопрос задан: 11 March 2019 13:57
2
ответа
Есть ли способ завершить поток после пропуска окончательного значения?
У меня есть исходный поток, который не завершается, но мне нужен оператор, который завершит работу наблюдателей после того, как полученное значение удовлетворяет некоторым требованиям, чтобы сделать его последним элементом для наблюдателей. В данный момен
вопрос задан: 18 January 2019 22:15
2
ответа
Разница между будущим и моно
В реактивном программировании (Java) чем отличается Future < T > и (Project Reactor) Mono < T & gt ;? Оба, кажется, средства для доступа к результату асинхронного вычисления в ...
вопрос задан: 17 January 2019 15:51
2
ответа
RX против очередей сообщений, таких как rabbitmq или zeromq? [закрыто]
Я совершенно новичок в этих парадигмах параллелизма высокого уровня и начал использовать привязки scala RX. Поэтому я пытаюсь понять, чем RX отличается от очередей обмена сообщениями, таких как RabbitMQ или ZeroMQ? Oни ...
вопрос задан: 11 January 2014 10:29
2
ответа
Расширения RX “Решили” проблему сложного событийно-управляемого программирования?
Я использовал Rx на новом финансовом аналитическом проекте, который получает все данные асинхронно. Я был довольно поражен своей персональной производительностью и сколько еще понятный мой основанный на событии код...
вопрос задан: 11 February 2010 10:28
2
ответа
Использование Системы. Реактивный в.NET 3.5 (в поставлющемся продукте) [закрытый]
Этот вопрос больше не является актуальным теперь, когда Microsoft выпустила нужную версию платформы Rx по devlabs Исходному Вопросу, я загрузил инструментарий Silverlight 3 и повторно основывал Систему....
вопрос задан: 8 January 2010 01:48
1
ответ
Как отобразить прогресс для комплекса Observable?
Интересно, как отобразить прогресс для сложного Observable, когда я использую flatMap, например так: Observable < Int > .from ([1,2,3,4]) .flatMap {queryApi ($ 0)} .flatMap {queryApi2 ($ 0)}. flatMap {...
вопрос задан: 30 March 2019 22:56
1
ответ
Как сделать реактивную гексагональную архитектуру
Я всегда слышал, что гексагональная архитектура должна быть независимой от любой платформы и использовать интерфейсы (SPI) для делегирования каждой части кода, которая не принадлежит бизнес-уровню. Но как создать ...
вопрос задан: 17 March 2019 19:18
1
ответ
Кто сделал RxJS / ReactiveX?
Мне интересно, кто запустил ReactiveX / RxJS? Rx, кажется, реализован на многих языках / платформах, мне интересно, каково его происхождение? Какой проект был первым? RxJS интенсивно используется в ...
вопрос задан: 10 March 2019 17:05
1
ответ
RX-Android + ViewModel + Retrofit не вызывает OnComplete ()
Я не могу получить метод OnComplete () для вызова после обработки всех элементов. Мне нужно сделать это для того, чтобы (как минимум, скрыть представление загрузки). Я немного новичок в JavaRX, поэтому я не знаю, где ...
вопрос задан: 2 March 2019 23:17
1
ответ
RxJs, не отображается в DOM, но консоль работает
Почему выходные данные отображаются только в одном элементе (# skip-result или # different-result), а не в обоих но если я попытаюсь вывести результат из этих двух наблюдаемых ниже на консоль, это сработает, вы можете
вопрос задан: 21 February 2019 08:19
1
ответ
Как реализовать выполнение процесса как реактивное `Observable [String]
Я хочу представить выполнение внешнего процесса в виде Observable [String], где String - строка из вывода процесса. Вот пример того, что я делаю, это работает: import monix.eval.Task import monix.execution ....
вопрос задан: 22 January 2019 18:27
1
ответ
Буферизация RxJava - игнорирование нулевых элементов
Вот код, который у меня есть для буферизации и преобразования входящих событий: public Publisher < Collection < EventTO > > logs (String eventId) {ConnectableObservable < Event > ...
вопрос задан: 20 January 2019 04:24
1
ответ
ORM Framework для реактивных приложений
Я искал Spring-data-r2dbc для реактивного доступа к БД. Но, похоже, он не обеспечивает поддержку ORM, как указано на странице проекта, это не платформа ORM. Какие есть варианты ...
вопрос задан: 19 January 2019 18:22
1
ответ
Как реактивный Java-доступ к данным из couchbase?
Я работаю с пружиной 5 и реактивного программирования с couchbase. Кто-нибудь может объяснить подробно, как реактивная Java получает данные из couchbase? Как couchbase обеспечивает реактивную поддержку? Спасибо ...
вопрос задан: 18 January 2019 11:07
1
ответ
Миграция HystrixCommands в Resilience4j
Учитывая, что Hystrix переходит в режим обслуживания, я работаю над переносом (довольно большой) кодовой базы в Resilience4j. Я интенсивно использую следующий шаблон с Hystrix: новый HystrixCommand < ...
вопрос задан: 17 January 2019 15:16
1
ответ
Как манипулировать объектами, поступающими из Flux < Object > со значением, полученным из метода, испускающего Mono < Items > неблокирующим способом?
Я пытаюсь манипулировать моими объектами, полученными из Flux, с данными, полученными из Mono, где методы, излучающие Flux объекта и Mono элементов, являются разными вызовами API. Проблема в том, что я ...
вопрос задан: 17 January 2019 13:32
1
ответ
Фильтры для приложения весенней загрузки webflux, которые возвращают ResponseEntity <? >
Мое весеннее загрузочное приложение настроено как реактивное. Но мои конечные точки API REST настроены для возврата ResponseEntity без Mono или Flux. @GetMapping ("/ wiki / test") public ResponseEntity <? > ...
вопрос задан: 16 January 2019 15:56
1
ответ
Поведение ConnectableObservable в RxJava2?
Я использую Observable myObs, который испускает один и только один элемент и никогда не завершается. Я хочу разделить этот элемент на несколько подписчиков в разное время. .replay (1) преобразует источник в ...
вопрос задан: 13 July 2018 20:29
1
ответ
Использовать случайное наблюдение x количество раз
У меня есть Observable, который реализует обработку ошибок в методе onErrorResumeNext. getMyObservable (params) .take (1) .doOnError (e - & gt; {}) ...
вопрос задан: 13 July 2018 07:17
1
ответ
IConnectableObservables в Rx
Кто-то может объяснить различия между Заметным и ConnectableObservable? Документация Расширений Rx очень редка, и я не понимаю, в каких случаях ConnectableObservable...
вопрос задан: 19 October 2010 00:56
1
ответ
Реактивная Платформа для примеров.NET, которые доказывают ее [закрытую] полноценность
Было небольшое количество шумихи вокруг новой Реактивной Платформы в.NET 4.0. В то время как я думаю я undestood его фундаментальное понятие, я не полностью продаюсь это, это настолько полезно. Можно ли придумать пользу...
вопрос задан: 11 February 2010 10:39