Описание тега system.reactive
System.Reactive относится к реактивным расширениям для.NET, также известным как Rx. Rx предоставляет разработчикам модель реактивного программирования поверх универсального IObservable.<t> интерфейс, в отличие от традиционной модели императивного программирования или других моделей реактивного программирования, которые строго полагаются на события.NET или определенные API.
</t>
2
ответа
Реактивный внутренний номер фиксированный Интервал между асинхронными вызовами, когда вызов длиннее интервала
Вот мой Interval определение: m_interval = Observable.Interval(TimeSpan.FromSeconds(5), m_schedulerProvider.EventLoop) .ObserveOn(m_schedulerProvider.EventLoop) .Select(l => Observable.FromAsync(DoWork)) .Concat() .Subscribe(); В приведенном выше…
30 сен '15 в 19:42
2
ответа
Ищите более декларативный способ Rx для наблюдения за изменением свойств элемента
У меня есть коллекция, которую можно наблюдать с точки зрения Rx, предметы также можно наблюдать (с точки зрения Rx). Я хочу иметь возможность наблюдать, когда изменяются свойства элементов в коллекции, но размер коллекции можно изменять - добавлять…
30 апр '17 в 20:25
1
ответ
Разделить IObservable<byte []> на символы, а затем на строку
Rx великолепен, но иногда трудно найти элегантный способ что-то сделать. Идея довольно проста. Я получаю события с байтом [], этот массив может содержать часть строки, несколько строк или одну строку. То, что я хочу, это найти способ иметь IObservab…
03 июл '15 в 13:48
2
ответа
Вызов OnNext при изменении свойства
Я думаю, что я плотный здесь. У меня есть два класса, один из которых содержит список другого - вот урезанная версия: Class Service Private _ratesList As New List(Of Rate) Public Property Rates As IEnumerable(Of Rate) Public Sub AddRate(rate As Rate…
26 янв '15 в 17:30
1
ответ
Реактивные расширения: разрешается только один подписчик для каждого типа
Есть ли способ гарантировать, что для общего типа может быть зарегистрирован максимум один подписчик на тип? Пример объяснил бы это лучше: public interface Message { } public class Command : Message { } public class Event : Message { } public class …
26 сен '13 в 07:36
1
ответ
Как позволить ReactiveCommands наблюдать их собственный IsExecuting наблюдаемый
У меня есть несколько команд в моей ViewModel, и я хочу, чтобы CanExecute каждой кнопки был привязан к наблюдаемому занятию, которое определено, поскольку ни одна из кнопок в данный момент не выполняется. Вот то, что я придумал, но, очевидно, это пр…
27 апр '14 в 11:41
1
ответ
Есть ли "полный" набор функций / операторов для FRP?
Функциональное реактивное программирование - это подход к определению побочных программ чисто функциональным способом. Недавно я использовал rxscala, который является портом порта Java/Scala ReactiveX. Он основан на концепции Observables, которые мо…
15 июн '15 в 18:19
6
ответов
Как я могу получить IObservable<T> в Rx из "нестандартного" события?
Вот что я имею в виду. Предположим, я работаю с API, который предоставляет события, но эти события не соответствуют стандарту. EventHandler или же EventHandler<TEventArgs> подпись. Например, одно событие может выглядеть так: Public Event Updat…
26 май '10 в 16:49
2
ответа
Как правильно подписаться на Измененную последовательность ReactiveObject?
Еще один вопрос по поводу ReactiveUi. У меня есть ViewModel для редактирования формы. Модель является ReactiveObject. Я хочу включить savecommand только тогда, когда произошли изменения объекта. Моя попытка: var canSaveCommand = this.WhenAnyValue(vm…
10 июл '17 в 20:32
1
ответ
Отмена длинного потока Rx
Если у меня есть поток с длительной работой, что-то вроде: inputStream.Select(n => Task.Run(() => { // Long running operation Thread.Sleep(TimeSpan.FromSeconds(5)); return n * n; }).ToObservable()) .Switch() .Subscribe(result => { // Use re…
31 янв '13 в 12:07
1
ответ
Как определить, ожидает ли Observable другого объекта с помощью RxJS (например, для индикатора запроса Ajax)
Во время изучения RxJS мне интересно: Как создать Observable, которое сообщает, имеет ли Observable X значение после Observable Y? В качестве примера необходимо указать, существует ли ожидающий ответ Ajax-запрос? Как и ожидание с Bacon.js.
22 апр '13 в 17:50
2
ответа
Опрос базы данных с помощью Reactive Extensions
Мне нужно своевременно запрашивать базу данных, чтобы узнать состояние устаревшей системы. Я думал об упаковке запроса вокруг Observable, но я не знаю правильный способ сделать это. По сути, это будет один и тот же запрос каждые 5 секунд. Но боюсь, …
14 ноя '15 в 23:02
1
ответ
Создать IObservable из метода и других
Правильно ли написан код ниже для возврата IObservable с точки зрения библиотеки Rx? Кажется, это работает правильно, но интересно, я использую это правильно. private IObservable<SearchResult[]> Search(string query) { return Observable.Create(…
12 авг '13 в 20:12
4
ответа
EventBus/PubSub против (реактивных расширений) RX с точки зрения ясности кода в однопоточном приложении
В настоящее время я использую архитектуру / шаблон EventBus / PubSub с Scala (и JavaFX) для реализации простого приложения для организации заметок (вроде клиента Evernote с некоторыми дополнительными функциями отображения разума), и я должен сказать…
25 мар '14 в 21:33
2
ответа
Как реализовать опрос с использованием Observables?
У меня есть параметризованный вызов rest, который должен выполняться каждые пять секунд с разными параметрами: Observable<TResult> restCall = api.method1(param1); Мне нужно создать Observable<TResult> который будет опрашивать restCall ка…
23 окт '13 в 17:00
1
ответ
Должен ли я вызывать Dispose для субъекта Reactive Extensions (Rx)<T>
Я использую объект Reactive Extensions (Rx) в качестве прямой замены для событий C#, например, так: public class MyClass { private Subject<string> subject; public IObservable<string> WhenSomethingHappened { get { return this.subject.AsOb…
20 июн '14 в 08:32
1
ответ
Может ли конечная точка System.Web.Http быть IObservable?
Может ли конечная точка System.Web.Http быть IObservable? Можно ли это сделать при использовании таких атрибутов, как Route и AcceptVerbs? По сути, я хочу превратить следующий пример кода в поток IObservable, поэтому я подписываюсь и обрабатываю его…
06 ноя '17 в 06:32
2
ответа
Удаление подписки - ожидает завершения действия подписки?
var sub = observable.Subscribe(data => my_action(data)); Когда я избавляюсь sub Переменная будет отписываться. Хорошо, но при этом будет ждать my_action закончить, если он уже был вызван? Обновление 1: я прошу сознательного решения, а не побочных…
23 дек '16 в 07:58
0
ответов
Миграция асинхронной команды ReactiveUI с 4.6.1 на 7.0
Как я могу преобразовать это в ReactiveCommand из 7.0: private void SetCanRunProcessCommand() { _runProcessCommand = new ReactiveAsyncCommand(CanRunProcess(null)); _runProcessCommand.RegisterAsyncAction(RunProcess); _runProcessCommand.ThrownExceptio…
16 май '16 в 14:04
1
ответ
Синхронный код VirusTotal для Rx включен асинхронно (и, возможно, некоторый анализ JSON)
В прошлый раз, когда я разместил здесь вопрос, все предоставили отличное руководство по решению моей проблемы. Двигайтесь вперед во времени и вот другое. Я пытаюсь переделать небольшой вспомогательный инструмент, который проверяет URL и файлы на пре…
09 июн '12 в 17:59