0
ответов
Throttle Rx.Observable без пропуска значений
Метод Throttle пропускает значения из наблюдаемой последовательности, если другие следуют слишком быстро. Но мне нужен способ просто задержать их. То есть мне нужно установить минимальную задержку между пунктами, без пропусков...
вопрос задан: 25 July 2012 16:43
0
ответов
скользящее временное окно реактивных расширений
У меня есть последовательность биржевых тиков, и я хочу взять все данные за последний час и обработать их. Я пытаюсь добиться этого с помощью реактивных расширений 2.0. Читал на другом...
вопрос задан: 19 July 2012 10:52
0
ответов
Observable.Defer -нужно пояснить, что именно он делает
Скажем, я хочу сгенерировать асинхронный поток случайных чисел, который выдает новое значение каждые 100 миллисекунд. Пока я пытался найти решение, моя первая попытка выглядела примерно так :...
вопрос задан: 12 July 2012 18:38
0
ответов
Существует ли метод Rx для периодического повторения предыдущего значения при отсутствии входящих значений?
Вариант использования, с которым я столкнулся, и я подозреваю, что я не единственный, для метода, подобного :IObservable Observable.RepeatLastValueDuringSilence (this IObservable inner,...
вопрос задан: 12 July 2012 12:06
0
ответов
Должен ли я предоставлять IObservable на своих интерфейсах?
У нас с коллегой спор. Мы пишем приложение.NET, которое обрабатывает огромные объемы данных. Он получает элементы данных, группирует их подмножества в блоки по некоторым...
вопрос задан: 10 July 2012 17:02
0
ответов
Каков наилучший способ «ограничить скорость» потребления Observable?
Мне приходит куча событий, и я должен выполнить ВСЕ из них без потерь,но я хочу убедиться, что они буферизуются и потребляются в соответствующие временные интервалы. У кого-нибудь есть решение?...
вопрос задан: 1 July 2012 17:44
0
ответов
Реактивные расширения — свойства обновляют друг друга
У меня есть 2 элемента управления DecimalUpDown, num_one и num_two, привязанные к свойствам First и Second соответственно. При изменении First он свяжется с сервером, чтобы вычислить значение Second, и наоборот....
вопрос задан: 28 June 2012 18:35
0
ответов
Использование IObservable вместо событий
Я недавно читал об IObservable. До сих пор я просматривал различные вопросы SO и смотрел видео о том, что они могут сделать. Весь механизм «push», я думаю, блестящий, но я все еще . ..
вопрос задан: 25 June 2012 13:54
0
ответов
Как обрабатывать исключения в OnNext при использовании ObserveOn?
Мое приложение завершает работу, когда наблюдатель выдает ошибку в OnNext при использовании ObserveOn(Scheduler.ThreadPool). Единственный способ, который я обнаружил, чтобы справиться с этим, - это использовать собственный метод расширения...
вопрос задан: 25 June 2012 03:44
0
ответов
Невоспроизведение горячего наблюдаемого
Исходный вопрос У меня есть сценарий, в котором у меня есть несколько последовательностей IObservable, которые я хочу объединить с помощью Merge, а затем прослушать. Однако, если один из них вызывает ошибку, я не хочу, чтобы она...
вопрос задан: 19 June 2012 12:59
0
ответов
Регулирование событий/постановка в очередь - Реактивные расширения?
Я хочу реализовать регулирование в одной из моих моделей представления. Это приложение Silverlight, однако я не думаю, что это особенно важно. Рассмотрим класс с тремя...
вопрос задан: 17 June 2012 15:57
0
ответов
Реактивные расширения: обработка событий пакетами + добавление задержки между каждым пакетом
У меня есть приложение, которое в некоторые точки вызывают 1000 событий почти одновременно. Что я хотел бы сделать, так это разбить события на куски по 50 элементов и начать их обработку каждые 10 секунд. ...
вопрос задан: 7 June 2012 07:37
0
ответов
Отслеживать (количество) наблюдателей в Observable?
У меня есть наблюдаемая, которая представляет собой поток цен на акции. Если в моей наблюдаемой последовательности нет наблюдателей, я хотел бы иметь возможность отключиться от удаленного сервера, который предоставляет ...
вопрос задан: 31 May 2012 18:16
0
ответов
Является ли Reactive Extensions открытым исходным кодом?
Является ли Reactive Extensions открытым исходным кодом? Будет ли Microsoft открывать исходный код? Я хочу прочитать исходный код, чтобы лучше понять, как он реализован. Я хотел бы увидеть модульные тесты, чтобы я мог их запустить...
вопрос задан: 30 May 2012 14:22
0
ответов
Реактивные расширения подходят для шины?
Я уже некоторое время использую Rx для создания шины событий (например, CQRS/ES) в одном приложении, и, похоже, это работает отлично. Однако, изучив множество различных источников событий...
вопрос задан: 10 May 2012 18:56
0
ответов
Отсутствуют методы расширения IObservable<>.Subscribe
Я использую расширения RX и WF4 для создания рабочего процесса, который реагирует на наблюдаемые сообщения для продвижения рабочего процесса. Для этого я ввожу объект, содержащий IObservable (ModuleMessage, являющийся моим...
вопрос задан: 9 May 2012 17:25
0
ответов
Почему я не должен& #39;не реализовывать IObservable?
Читая msdn о Reactive Extensions и тому подобном, я нашел рекомендацию, в которой говорилось, что я не должен реализовывать IObservable, а использовать Observable.Create... К тому времени, когда я это прочитал, мой проект...
вопрос задан: 7 May 2012 10:33
0
ответов
Анализ Observable Network IO
Я пытаюсь использовать Rx для чтения из потока приема TCPClient и анализа данных в IObservable строки, разделенной символом новой строки "\r\n". Вот как я получаю из потока сокета......
вопрос задан: 7 May 2012 04:44
0
ответов
использовать RX для запуска событий в разное время?
У меня есть большая коллекция простых парных классов :public class Pair { public DateTime Timestamp; публичное двойное значение; } Они отсортированы по возрастанию метки времени. Я хочу инициировать событие с помощью...
вопрос задан: 3 May 2012 22:56
0
ответов
ожидание на наблюдаемом
Поэтому в печальные дни C #4.0 я создал следующий класс «WorkflowExecutor», который разрешал асинхронные рабочие процессы в потоке GUI, взломав продолжения IEnumerable «yield return» для ожидания...
вопрос задан: 24 April 2012 00:49
0
ответов
Обработка событий из журнала событий и реакция на определенный шаблон (Rx?)
Мне нужно обработать события, поступающие из EventLog. Это легко сделать, подключив EventLogWatcher к событию EventRecordWritten. Однако меня интересует запрос (eventid == 299 || eventid ==...
вопрос задан: 12 April 2012 17:38
0
ответов
сохранить состояние подписки IObservable в Rx
[этот вопрос относится к области реактивных расширений (Rx)] Подписка, которую необходимо продолжить при перезапуске приложения int nValuesBeforeOutput = 123; myStream.Buffer(nValuesBeforeOutput)....
вопрос задан: 11 April 2012 14:44
0
ответов
Как в Rx сгруппировать последние элементы через определенный период времени?
Извините, если заголовок не очень ясен, я не мог придумать ничего лучше... Я получаю пользовательский ввод в виде IObservable, и я хотел бы преобразовать его в IObservable
вопрос задан: 3 April 2012 00:14
0
ответов
Делайте «промежуточные IObservables» без сохранения конечных подписчиков в памяти на время жизни корневого IObservable
Например, рассмотрите это: e => e is T).Cast().Subscribe(наблюдатель); } ...
вопрос задан: 28 March 2012 04:25
0
ответов
Почему AsObservable и AsEnumerable реализованы по-разному?
Реализация Enumerable.AsEnumerable(этот источник IEnumerable) просто возвращает источник. Однако Observable.AsObservable(этот источник IObservable) возвращает ...
вопрос задан: 26 March 2012 14:22
0
ответов
Как запустить синхронизированную последовательность событий в потоке GUI в C#?
У меня есть приложение, которое должно выполнять следующие действия, предпочтительно в потоке графического интерфейса, поскольку именно там происходит большая часть действий и нет длительных операций: Подождите 1000
ФункА()
Подождите...
вопрос задан: 23 March 2012 19:19
0
ответов
Объединение Rx-потоков
Я пытаюсь смоделировать нетривиальный (для меня) Rx-запрос: В комнате есть Мужчины и Женщины.
Они входят и выходят из комнаты, а находясь в комнате, иногда меняют свое местоположение.
Каждый мужчина может...
вопрос задан: 18 March 2012 12:45
0
ответов
Чем IEnumerable отличается от IObservable под капотом?
Мне любопытно, чем IEnumerable отличается от IObservable под капотом. Я понимаю шаблоны pull и push соответственно, но как C# с точки зрения памяти и т. д. уведомляет подписчиков (для...
вопрос задан: 16 March 2012 18:58
0
ответов
Как я могу объединить два потока, упорядоченных, а затем сгруппированных по отметке времени?
У меня есть два потока объектов, каждый из которых имеет значение Timestamp. Оба потока идут по порядку, поэтому, например, метки времени могут быть Ta = 1,3,6,6,7 в одном потоке и Tb = 1,2,5,5,6,8 в другом. ...
вопрос задан: 16 March 2012 18:06
0
ответов
RX:Выполнять действие при запуске или удалении подписки?
Я хотел бы отслеживать количество активных подписок на мой IObservable? Я подумал, что смогу реализовать это, увеличивая/уменьшая значение счетчика всякий раз, когда «кто-то» вызывает Subscribe/...
вопрос задан: 13 March 2012 05:17