0
ответов
Как обрабатывать исключения из асинхронных методов в операторе SelectMany
Я пытаюсь обработать некоторые задачи асинхронно, используя Rx, например. var list = Enumerable.Range(0, 100) .ToObservable() .SelectMany(x => Observable.Start(() => { Console.WriteLine("...
вопрос задан: 11 March 2012 11:15
0
ответов
сбросить счетчик выше максимального временного интервала при агрегации на основе счетчика Rx
Фильтрация на основе счетчика без ограничения по времени IObservable filterStream = changes.Buffer (3); Как ввести сброс бездействия? Но как ввести тайм-аут TimeSpan tooLong, чтобы ...
вопрос задан: 4 March 2012 12:40
0
ответов
Фильтр Rx по критерию и n значений после критерия
Фильтр только по критерию изменяется.Where (p => Evaluate (p)). Subscribe (p => {// Do something}); Но как вы могли сделать так, чтобы вы получали значение критерия и n значений после того, как критерий равен ...
вопрос задан: 3 March 2012 10:37
0
ответов
SynchronizationContext.Current имеет значение null при разрешении с помощью Unity в WPF
У меня есть код WPF, который выглядит примерно так. открытый класс AlphaProductesVM: BaseModel
{частный ObservableCollection <алфавитный_лист_продукта> _NwCustomers; private int i = ...
вопрос задан: 21 February 2012 12:41
0
ответов
Обновление ObservableCollection из другого потока
Я пытался разобраться с библиотекой Rx и работал над ней в WPF с помощью MVVM. Я разбил свое приложение на такие компоненты, как репозиторий и ViewModel. Мой репозиторий в состоянии чтобы предоставить ...
вопрос задан: 20 February 2012 17:31
0
ответов
Как мне динамически обновлять / добавлять элементы в / в IObservable ?
У меня есть наблюдаемая коллекция, для которой я хотят продолжать кормить объекты, и они должны доходить до наблюдателей даже после того, как кто-то подписался на них (что, конечно же, является основной целью наблюдаемого). Как ...
вопрос задан: 16 February 2012 16:12
0
ответов
Observables vs Tasks - предпочтительная реализация?
Я просто хочу получать данные асинхронно, а после получения данных показывать их в пользовательском интерфейсе (Winforms). Используя .net 4.0, есть 2 способа, которыми я могу это реализовать (я знаю, что их больше, но я ...
вопрос задан: 9 February 2012 18:05
0
ответов
Подводные камни при попытке использовать PLINQ над долгоиграющими генераторами?
У меня есть несколько методов бесконечных генераторов, включая некоторые долгоиграющие и бесконечно долгоиграющие генераторы. IEnumerable ExampleOne() { while(true) // этот блокирует на несколько секунд ...
вопрос задан: 25 January 2012 09:51
0
ответов
Как мне изменить реализацию Rx Builder, чтобы исправить исключение переполнения стека?
I ' m пытается придумать Rx Builder для использования Reactive Extension в синтаксисе F # Computation Expression. Как исправить, чтобы не взорвал стек? Как в примере ниже.
И это ...
вопрос задан: 24 January 2012 14:26
0
ответов
Утекает ли ReactiveUI подписки?
Я посмотрел на примеры ReactiveUi из блогов и остался в недоумении, есть ли под ReactiveUI какой-то механизм управления подписками или примеры игнорируют тот факт, что ...
вопрос задан: 19 January 2012 15:45
0
ответов
Что делать с утилизируемыми IObservers?
Я использую Reactive Extensions для простой обработки событий в моих ViewModels (Silverlight и/или Wp7 приложениях). Для простоты предположим, что у меня есть такая строка в ctor моей VM: Observable....
вопрос задан: 17 January 2012 11:00
0
ответов
Как разделить наблюдаемый поток на куски, в зависимости от второго потока?
Я думал, что это легко, но сейчас мой мозг тает .. Проблема Дана следующий поток IObservable :
1
1
0
0
0
1
0
0
1
0
1 Я хочу разбить его на IObservable <...
вопрос задан: 12 January 2012 23:01
0
ответов
Исключение между потоками при использовании газа RX
Я получаю недопустимый доступ между потоками. При использовании RX Throttle Вот мой код: yObs.SubscribeOnDispatcher () .DistinctUntilChanged () .Throttle (TimeSpan ....
вопрос задан: 7 January 2012 02:22
0
ответов
В чем разница между Run и Do в Rx?
В старых версиях Reactive Extensions были методы расширения Run и Do для IEnumerable. Кажется, что они оба делают одно и то же, и я не знаю, в чем разница. Я спрашиваю ...
вопрос задан: 4 January 2012 18:30
0
ответов
Какой хороший способ сообщить о прогрессе из репозитория в пользовательский интерфейс
Я ищу хороший способ или, по крайней мере, некоторое представление о том, как четко сообщать о прогрессе на уровне пользовательского интерфейса. Моя ситуация такова: у меня есть репозиторий на уровне инфраструктуры, который ...
вопрос задан: 31 December 2011 15:12
0
ответов
Модульное тестирование события с использованием реактивных расширений
Я использую реактивные расширения для .NET (Rx), чтобы отображать события как IObservable . Я хочу создать модульный тест, в котором я утверждаю, что запускается определенное событие. Вот упрощенная версия ...
вопрос задан: 8 December 2011 12:19
0
ответов
SignalR против реактивных расширений
Является ли SignalR тем же самым, что и реактивные расширения? Можете ли вы объяснить, почему или почему нет?
вопрос задан: 7 December 2011 19:58
0
ответов
Перехват исключений, которые могут быть вызваны действием подписки OnNext
Я новичок в Rx.NET. Можно ли поймать исключение, которое может вызвать любой из подписчиков? Возьмем следующий ... handler.FooStream.Subscribe (_ => throw new ...
вопрос задан: 30 November 2011 18:00
0
ответов
Уловки для отладки с помощью реактивных расширений?
Я ищу идеи, как сделать RX более легко отлаживаемым. Может быть очень сложно найти точку отказа, когда источник проходит через комбайнеры, дросселирующие устройства, публикует и тому подобное.
...
вопрос задан: 22 November 2011 02:06
0
ответов
Объединение нескольких источников событий в один IObservable с Rx
Это вопрос о том, как использовать Reactive Extensions (Rx) в конкретном сценарии, связанном с событием. Цель состоит в том, чтобы взять несколько классов, которые запускают какое-то событие, и собрать их в один ...
вопрос задан: 19 November 2011 13:55
0
ответов
Добавление наблюдаемой последовательности после подписки
Мы используем Rx для мониторинга активности в нашем приложении silverlight, чтобы мы могли отображать сообщение пользователю после периода бездействия. Мы превращаем события (движения мыши и т. Д.) В ...
вопрос задан: 11 November 2011 11:39
0
ответов
Тайм-аут реактивных расширений, который не останавливает последовательность?
Я пытаюсь создать IObservable , который возвращает истину, если сообщение UDP было получено в последние 5 секунд, и если истекло время ожидания, ложь возвращается. Пока у меня есть это: public ...
вопрос задан: 9 November 2011 12:24
0
ответов
Использование реактивного расширения (Rx) для получения сообщений MSMQ с использованием асинхронного шаблона (queue.BeginReceive, queue.EndReceive)
Я использовал Rx какое-то время для событий в моих проектах и специально для программирования Socket, и что хорошо, так это то, что у него все хорошо. Управление моим кодом, преимущество в производительности и многое другое для ...
вопрос задан: 4 November 2011 07:06
0
ответов
Запуск задачи сразу, затем по временному интервалу с помощью Rx framework
Я пытаюсь запустить свою задачу сразу, затем запустить ее по временному интервалу. Я написал следующее: var syncMailObservable = Observable.Interval(TimeSpan.FromSeconds(15));
syncMailObservable.Subscribe(...
вопрос задан: 17 October 2011 21:36
0
ответов
Как события WinRT взаимодействуют с .NET
В последнем видео от команды Rx Барт Де Смет: Обновление Rx - .NET 4.5, Async, WinRT Я видел, что события WinRT открываются для .NET с помощью некоторых действительно странных метаданных, точнее - парных методов add_ / remove_ ...
вопрос задан: 15 October 2011 11:53
0
ответов
Реактивное удаление наблюдаемой подписки
Если у меня есть доступ к объекту IObservable, который, как я знаю, будет возвращать только один элемент, будет ли это работать и будет ли это наилучшим шаблоном использования? IDisposable Disable = null;
Disposable = myObservable ....
вопрос задан: 9 October 2011 12:06
0
ответов
Приостановить и возобновить подписку на холодном IObservable
Используя Rx, я хочу, чтобы функция приостановки и возобновления работала в следующем коде: Как реализовать Pause () и Resume ()? Static IDisposable _subscription; static void Main (string [] args) {...
вопрос задан: 1 October 2011 12:22
0
ответов
Поддерживают ли реактивные расширения скользящие буферы?
Я использую реактивные расширения для сопоставления данных в буферы по 100 мс: this.subscription = this .dataService .Where (x =>! string.Equals ("FOO", x.Key.Source)) .Buffer (TimeSpan.FromMilliseconds (...
вопрос задан: 29 September 2011 13:07
0
ответов
В чем разница между SubscribeOn и ObserveOn
Я только что открыл для себя SubscribeOn, что заставляет меня задуматься, следует ли мне использовать его вместо ObserveOn. Google проводил меня здесь и здесь, но ни один из них не помог мне ощутить разницу: это кажется невероятным ...
вопрос задан: 28 September 2011 06:39
0
ответов
Как я могу создать наблюдаемый Rx, который перестает публиковать события, когда последний наблюдатель не подписывается?
Я создам наблюдаемый (различными способами) и верну его заинтересованным лицам, но когда они закончат слушать, я хочу снести наблюдаемое, чтобы оно не продолжало потреблять ...
вопрос задан: 22 September 2011 04:16