Результаты поиска по запросу "system.reactive"
Как использовать Observable.FromEvent вместо FromEventPattern и избегать строковых литералов имен событий
Я изучаю Rx в WinForms и имею следующий код: // Create an observable from key presses, grouped by the key pressed var groupedKeyPresses = Observable.FromEventPattern<KeyPressEventArgs>(this, "KeyPress") .Select(k => k.EventArgs.KeyChar) ...
@ Jmix90 оригинальный вопрос обновлен с моим кодом. Обратная связь приветствуется.
ного новичок в Rx.NET. Можно ли поймать исключение, которое может быть выдано любым из подписчиков? Возьми следующее ... handler.FooStream.Subscribe( _ => throw new Exception("Bar"), _ => { });В настоящее время я ловлю на основе подписки с ...
в этой другой коллекции?
я есть коллекция ObservableCollection, на которую нужно ссылаться для определенного элемента. Если элемент отсутствует, мне нужно отслеживать его с помощью Reactive Extensions, чтобы узнать, появляются ли элементы когда и когда, но мне нужна ...
Пауза и возобновить подписку на холодную IObservable
С помощьюRx [http://msdn.microsoft.com/en-us/library/hh212048%28v=VS.103%29.aspx]Я хочу приостановить и возобновить работу в следующем коде: Как реализовать Pause () и Resume ()? static IDisposable _subscription; static void Main(string[] args) ...
В чем разница между SubscribeOn и ObserveOn
Я только что обнаружилSubscribeOnчто заставляет меня задуматься, стоит ли мне использовать это вместоObserveOn, Google взял меняВот [http://social.msdn.microsoft.com/Forums/en-US/rx/thread/6944f097-00f4-42ad-8f19-d01d1aa939f4/] а ...
Поддерживают ли реактивные расширения скользящие буферы?
Я использую реактивные расширения для сортировки данных в буферы по 100 мс: this.subscription = this.dataService .Where(x => !string.Equals("FOO", x.Key.Source)) .Buffer(TimeSpan.FromMilliseconds(100)) .ObserveOn(this.dispatcherService) .Where(x ...
Буферизуйте данные из курсора базы данных, сохраняя интерфейс
У меня есть каталог базы данных, который заполнен, и курсор, который можно использовать для извлечения объектов. Этот каталог, очевидно, может быть очень большим, и я хотел бы использоватьReactiveUIбуферизировать данные, сохраняя привязанность ...
Есть ли более элегантный способ объединить наблюдаемые, когда возвращаемый тип не важен?
У меня есть модель представления, похожая на ReactiveUI. У этого есть несколько свойств различных типов, которые стреляютNotifyPropertyChanged события, и я хочу подписать метод, который будет вызываться, когда любой запущен, но меня не интересуют ...
Добавление наблюдаемой последовательности после подписки
Мы используем Rx для мониторинга активности в нашем приложении silverlight, чтобы мы могли отображать сообщение пользователю после периода бездействия. Мы превращаем события (движения мыши и т. Д.) В наблюдаемые, а затем объединяем наблюдаемые ...
Stream Multicasting - один раз считайте поток, но обрабатывайте его по-разному, с минимальной буферизацией
Для масштабируемости и экономии ресурсов лучше избегать считывания всего входного потока в память, а вместо этого пытаться обрабатывать его как поток, считывая небольшие порции за раз. Это легко сделать в .NET, когда у вас есть одна вещь, которую ...