Описание тега rx.net
Reactive Extensions (Rx) - это библиотека для создания асинхронных программ и программ, основанных на событиях, с использованием наблюдаемых последовательностей и операторов запросов в стиле LINQ.
1
ответ
Может ли конечная точка System.Web.Http быть IObservable?
Может ли конечная точка System.Web.Http быть IObservable? Можно ли это сделать при использовании таких атрибутов, как Route и AcceptVerbs? По сути, я хочу превратить следующий пример кода в поток IObservable, поэтому я подписываюсь и обрабатываю его…
06 ноя '17 в 06:32
1
ответ
Пакет Nuget для.netcore TestScheduler
Это довольно глупо, но я не могу найти пакет.net rx nuget, который содержит TestScheduler Пожалуйста, укажите мне в правильном направлении.
01 сен '17 в 22:10
2
ответа
Как получить последние измененные события IObservable<IObservable <T >>?
В моей системе много объектов статуса - статус соединения, загрузка процессора, зарегистрированные пользователи и так далее. Все такие события объединены в один наблюдаемый поток. Я хочу сделать утилиту администратора, чтобы показать фактическое сос…
22 май '15 в 15:45
1
ответ
Попарный оператор с использованием.buffer в rx.net
Мне нужно автоматически выполнять резервное копирование моих файлов с внешних драйверов (например, USB-ключей). Когда драйвер подключен. Чтобы узнать, когда новый USB или жесткий диск вставлен, я использовал наблюдаемый, проблема в том, что единстве…
09 сен '17 в 17:23
1
ответ
Безопасно ли ожидать Задачу в методе OnNext() Обозревателя?
Я создал пользовательский Observer, который в основном выполняет асинхронную задачу в своем методе OnNext(). Я задаюсь вопросом, хорошая ли идея сделать это, имея в виду, что async void не велика. public class MessageObserver : IObserver<Message&…
20 авг '18 в 15:36
1
ответ
Динамически объединяющие последовательности с Reactive Extensions
Я хочу создать последовательность, которая объединяет одну или несколько последовательностей, созданных динамически (во время выполнения). Я пробовал с mySequence = mySequence.Concat(anotherSequence), но это нарушает текущие подписки на mySequence т…
03 июл '16 в 20:41
2
ответа
Возьмите последний предмет, переданный в Наблюдаемую (Последовательность)
У меня есть IObservable<Item> внутри класса, и я хочу предоставить доступное только для чтения свойство, которое предоставляет последний элемент, переданный наблюдаемому в данный момент времени. Так что это обеспечит единственное значение Item…
04 фев '17 в 16:08
2
ответа
Как мне превратить систему опроса в Rx.Net IObservable?
У меня есть игра (на основе MonoGame / XNA) с методом обновления, например, так: public void Update(GameTime gameTime) { component.Update(gameTime); } Я хотел бы преобразовать это в шаблон Reactive. Мое текущее решение: public void Initialize() { up…
03 июл '16 в 15:13
0
ответов
Как мне обрабатывать побочные потоки в Rx.Net?
Я строю симуляцию с использованием Rx.Net. Пользовательский ввод моделируется как поток преобразования состояния в исходное состояние. С помощью Scan Я могу разрешить эти преобразования в текущем состоянии. Проблема в том, что преобразования могут и…
07 июл '16 в 20:21
0
ответов
Rx Java против Rx C#
Я начинаю изучать Rx для C# с этой электронной книгой, но так как я также много работаю с Java, мне интересно, как Rx для C# и Rx для Java могут отличаться. Таким образом, я могу выучить один, а затем просто сосредоточиться на различиях между ними, …
08 фев '18 в 00:10
2
ответа
Реализация Rx.Net GroupBy отсутствует последовательность элементов редко
Я использую RX 2.2.5. У меня есть 2 просмотра, которые загружают суб-заказы с _transportService .ObserveSubOrder(parentOrder.OrderId) .SubscribeOn(_backgroundScheduler) .ObserveOn(_uiScheduler) .Where(subOs => subOs != null) .Snoop("BeforeGrpBy")…
27 окт '16 в 06:07
1
ответ
Rx.Net: наблюдать асинхронные события бесконечно
У меня есть вспомогательный класс, который сохраняет текстовые сообщения в локальной файловой системе. Этот метод возвращает Task объект, и является асинхронным по определению. Я хочу иметь возможность наблюдать, когда вызывается этот метод, поэтому…
19 мар '17 в 11:05
1
ответ
Реактивные расширения для разработчиков.NET
Я нашел некоторую информацию об этом, но у меня есть несколько путаницы по этому поводу. Поэтому, когда нам нужно использовать этот RX.NET. Что важно использовать эти предметы? Когда мне нужно это использовать?
06 дек '18 в 05:05
1
ответ
Есть ли расширение как StartWith, но для конца наблюдаемой последовательности?
Я хочу добавить дополнительный "закрывающий" элемент к моей наблюдаемой последовательности. Есть ли расширение Reactive LINQ, подобное StartWith но для конца наблюдаемой последовательности? Вот приблизительное значение того, что я хочу, хотя, похоже…
12 ноя '16 в 20:19
1
ответ
Rx.Net Использование Observable.Create вместо Subject
У меня есть код, который использует тему для создания наблюдаемой. Я могу передать значение в наблюдаемый поток с использованием subject.onNext (значение). Проблема в том, что если я подпишусь на это наблюдаемое после того, как значение будет переда…
29 янв '19 в 20:43
0
ответов
Rx.net, как запустить последовательность (или иметь побочный эффект) только на первой подписке?
У меня есть экземпляр 'Conversation', который принимает поток сообщений, обрабатывает сообщения в соответствии с внутренним состоянием и выставляет свойство, которое можно наблюдать из сообщений. Внутренне он использует State Pattern для делегирован…
16 апр '18 в 13:01
0
ответов
"Коллекции были изменены, операция перечисления может не выполняться" в диаграмме классов
Я хочу лучше понять код Rx, используя его диаграмму UML. Затем я использую сообщество VS2013 для его создания. Но это не удалось. Появляется диалог с предложением "коллекции были изменены; операция перечисления может не выполняться". Какова причина?…
20 янв '15 в 01:27
1
ответ
Как получить последнее известное значение IObservable?
Предположим, я создаю графический редактор с использованием Rx.Net. Пользователь может манипулировать холстом с помощью мыши. Применяемые манипуляции зависят от выбранного в данный момент инструмента. Например, может быть инструмент "рисовать" и "ст…
06 июл '16 в 16:01
0
ответов
Использование собственного планировщика для времени аудиопотока
В приложениях обработки звука многие события синхронизируются по времени аудиопотока (которое в первом приближении представляет собой просто число потребляемых выборок, умноженное на коэффициент), а не системное время, часто называемое временем стен…
04 май '16 в 21:33
1
ответ
.NET Задачи, которые ждут работы
Я хочу создать на сервере темы, которые ждут работы. Я хочу 1 поток на пользователя, который посещает сайт. Это работает, создавая цикл while с thead.sleep(100), но это кажется неэффективным. Мы отслеживаем каждую задачу, которая принадлежит каждому…
29 сен '16 в 16:09