0
ответов
Реактивные расширения в монофоническом режиме?
Этот вопрос давней давности обнаружил некоторые проблемы - Доступна ли Reactive Framework (RX) для использования в моно? Есть ли у кого-нибудь текущий опыт работы с Rx?
вопрос задан: 23 May 2017 12:26
0
ответов
Как мне предоставить последнее значение горячего наблюдаемого при подписке
У меня есть горячее наблюдаемое (из события), которое я вызываю DistinctUntilChanged, на котором будет несколько подписчиков, которые будут подписываться в разное время после запуска наблюдаемого, и ...
вопрос задан: 23 May 2017 12:25
0
ответов
Реактивный дроссель, возвращающий все элементы, добавленные в пределах временного интервала
При наличии IObservable есть ли способ использовать поведение дросселя (сброс таймера при добавлении элемента, но чтобы он возвращал коллекцию всех элементов, добавленных в течение этого времени? Buffer предоставляет ...
вопрос задан: 23 May 2017 12:01
0
ответов
RX Темы - следует ли их избегать?
У меня было мини-обсуждение этой темы в другой ветке, и я хотел бы получить отзывы людей по «плохим» сторонам тем. Люди, которые часто посещают форум RX, знают, что Э.Мейеру не нравится ...
вопрос задан: 23 May 2017 11:54
0
ответов
Как использовать IObservable/IObserver с ConcurrentQueue или ConcurrentStack
Я понял, что, когда я пытаюсь обработать объекты в параллельной очереди, использующей несколько потоков, в то время как несколько потоков могут помещать объекты в нее, идеальное решение состояло бы в том, чтобы использовать Реактивное...
вопрос задан: 23 May 2017 11:53
0
ответов
Руководство по System.Reactive.Joins
Я ищу введение/документацию по System.Reactive.Joins , который включает классы Pattern, Plan, QueryablePattern и QueryablePlan. Google ничего не выдает ("System....
вопрос задан: 23 May 2017 11:47
0
ответов
Каковы варианты использования потока данных TPL через реактивные расширения (Rx)
Я специально ищу написание некоторых алгоритмов обработки сигналов в одном или другом, или, возможно, в некоторой их комбинации . Производительность не имеет большого значения, ясность выражения намерения - это ...
вопрос задан: 4 April 2017 10:11
0
ответов
Select Many в Rx [закрыто]
Пожалуйста, дайте мне знать, как работает оператор SelectMany в Rx. Я тоже не знаю больше об этом операторе в Linq. Объясните пожалуйста это на простом примере, а также в чем...
вопрос задан: 28 November 2016 05:42
0
ответов
Заменят ли реактивные расширения (Rx) Библиотеку параллельных задач?
После ознакомления с примерами Rx.NET я был потрясен тем, насколько блестящая концепция и реализация реактивных расширений. Похоже, что он предлагает разработчикам более удобный шаблон ...
вопрос задан: 8 August 2016 13:36
0
ответов
Возможно ли использовать Observable.Buffer для чего-то другого, кроме времени?
Я искал примеры использования Observable.Buffer в rx, но не смог найти ничего более существенного, чем стандартная временная буферизация. Кажется, есть перегрузка, чтобы указать "...
вопрос задан: 18 February 2016 17:48
0
ответов
Когда использовать Observable.FromEventPattern, а не Observable.FromEvent?
У нас есть клиент, вызывающий очередь TIBCO EMS, и назначаются следующие события: var msgConsumer = _session.CreateConsumer (responseQueue);
var response = Observable.FromEvent <...
вопрос задан: 27 November 2015 01:34
0
ответов
Реактивный: последнее значение, которое должно быть получено IObservable
Я знаю, что следующий вызов является блокирующим и вернет первое значение в наблюдаемой последовательности: var result = myObservable.First (); В зависимости от того, какой тип темы я использую, это может быть разным ...
вопрос задан: 22 August 2015 14:11
0
ответов
CombineLatest, אָבער נאָר שטופּן פֿאַר די לינקס
איך דאַרפֿן צו ינסטרומענט אַ ווערסיע פון CombineLatest (איך וועט רופן עס WithLatest דאָ) וואָס רופט די סעלעקטאָר פֿאַר יעדער נומער אויף די לינקס און די לעצטע נומער אויף די רעכט. עס זאָל נישט שטופּן פֿאַר זאכן אויף די ...
вопрос задан: 28 July 2015 06:17
0
ответов
Есть ли более элегантный способ объединения наблюдаемых, когда тип возвращаемого значения не важен?
У меня есть модель представления, подобная ReactiveUI. У него есть несколько свойств разных типов, которые запускают события NotifyPropertyChanged, и я хочу подписаться на метод, который будет вызываться при срабатывании любого из них, но я ...
вопрос задан: 18 April 2015 04:42
0
ответов
Async Queue Processing With Reactive Extensions
Kunezihloko ezimbalwa ngalokhu, futhi lokhu ngiyakusebenza ... kodwa ngifuna ukwazi ukuthi ngingayisetha kanjani inombolo enkulu Imicu Yomsebenzi yokubhaliselwe kwami okubonakalayo ngasikhathi sinye. Nginakho okulandelayo ...
вопрос задан: 12 March 2015 23:18
0
ответов
Предотвращение перекрытия вызовов OnNext в Rx при использовании SubscribeOn (Scheduler.TaskPool)
У меня есть код, использующий Rx, вызываемый из нескольких потоков, который выполняет: subject.OnNext (value); // где subject - Subject Я хочу, чтобы значения обрабатывались в фоновом режиме, поэтому моя подписка ...
вопрос задан: 11 March 2015 11:23
0
ответов
Rx: Как я могу ответить немедленно и ограничить последующие запросы
Я хотел бы настроить подписку Rx, которая может отвечать на событие сразу, а затем игнорировать последующие события, которые происходят в течение указанного периода восстановления. Готовый к использованию Throttle / ...
вопрос задан: 10 February 2015 08:09
0
ответов
Ссылка исчезает при отладке / сборке (C #, VB.NET, VS2010)
Я использую MagicLibrary для нескольких компонентов. Я знал, что он был написан в Visual Studio 2003 и перекомпилировал его в Visual C # Express 2010. Он компилировал просто хорошо, и я мог видеть библиотеку в ...
вопрос задан: 18 September 2014 17:22
0
ответов
Fast Repeat TakeWhile вызывает бесконечный цикл
Как я могу сделать следующее наблюдаемое повторение, пока stream.DataAvailable не станет ложным?
В настоящее время похоже, что он никогда не останавливается. AsyncReadChunk и Observable.Return внутри раздела Defer make OnNext ...
вопрос задан: 17 September 2014 23:17
0
ответов
Полезно ли Observable.Interval для высокочастотных событий?
Я использую Observable.Interval, чтобы проверить, насколько хорошо работает определенный фрагмент кода клиент / сервер при разных нагрузках. Но, похоже, у него странное поведение. Observable.Interval (временной интервал = 0) ...
вопрос задан: 20 January 2014 13:25
0
ответов
Планировщик RX - Что это такое?
Я читал о RX и совершенно не понимал, для чего предназначен Планировщик? Может кто-нибудь объяснить?
вопрос задан: 24 July 2013 14:17
0
ответов
Примеры IQbservable [закрыто]
Я пытаюсь придумать несколько хороших примеров использования IQbservable и подумал Я спросил бы, использовал ли кто-либо это еще, или есть какие-нибудь идеи относительно того, как это могло бы использоваться или злоупотреблено? РЕДАКТИРОВАТЬ Это (IQbserv
вопрос задан: 5 June 2013 13:52
0
ответов
Реактивные расширения: параллелизм внутри абонента
Я пытаюсь сосредоточиться на поддержке параллелизма Reactive Extensions, и мне трудно получить результаты, к которым я стремлюсь. Так что я пока не могу этого понять. У меня есть источник, который излучает данные ...
вопрос задан: 20 May 2013 21:45
0
ответов
Реактивное расширение (Rx)актуальное руководство
Меня очень интересуют реактивные расширения, но я не могу найти актуальное руководство. Я начал с лечения асинхронной хандры с помощью реактивных расширений для.NET, но он устарел. Я могу...
вопрос задан: 14 May 2013 20:58
0
ответов
Как с помощью Rx игнорировать все значения, кроме самого последнего, когда работает мой метод Subscribe?
Используя Reactive Extensions, я хочу игнорировать сообщения, поступающие из моего потока событий, которые происходят во время работы моего метода Subscribe. т.е. иногда мне требуется больше времени, чтобы обработать сообщение, чем время...
вопрос задан: 17 April 2013 12:13
0
ответов
В чем концептуальная разница между SynchronizationContext и TaskScheduler
Стивен Тоуб написал в своем блоге, что SynchronizationContext и TaskScheduler являются абстракциями, которые представляют собой «планировщик», то есть вы даете какую-то работу, и она определяет, когда и где...
вопрос задан: 16 April 2013 14:17
0
ответов
Пример комбинированного потока данных TPL и Rx [закрыт]
Я просто хочу узнать, как использовать их вместе. Я понимаю, что они могут дополнять друг друга, я просто не мог найти пример того, как кто-то действительно это делает.
вопрос задан: 13 April 2013 10:19
0
ответов
Оператор Rx для различных последовательностей
ВАЖНО :описание результатов и некоторые другие подробности см. также в моем ответе. Мне нужно сгруппировать и отфильтровать последовательность объектов/событий, которые обычно реплицируются, буферизация...
вопрос задан: 26 August 2012 07:54
0
ответов
RX -Как подписаться на состояние условия, но только когда это состояние не меняется в течение x времени?
Знаете ли вы, как подписаться на состояние условия, которое остается в течение x времени? Например, если у меня есть BehaviorSubject, представляющий значение int между 0 -100, и это значение меняется со временем,...
вопрос задан: 3 August 2012 18:40
0
ответов
'WaitFor' наблюдаемая
Я нахожусь в ситуации, когда у меня есть список задач, над которыми я работаю (включить диск, изменить положение, дождаться остановки, отключить ). «Ждать» отслеживает IObservable, который я хочу...
вопрос задан: 30 July 2012 09:16