Вопросы по теме 'rx.net'
Как запустить сигнал RX со скользящим окном в зависимости от определенных условий
У меня есть горячий наблюдаемый поток данных датчика. Мне нужен наблюдаемый сигнал, который срабатывает только тогда, когда значение датчика ниже 15 в течение заданного периода времени. Если в любое время значение превысит 15, оно должно сбросить...
323 просмотров
schedule
15.09.2022
Утечка памяти при повторном подключении/отключении с реактивными сокетами
Я использую библиотеку реактивных сокетов, найденную на GitHub ( https://github.com/clariuslabs/reactivesockets ). и мне было интересно, если кто-то испытал утечку памяти, когда клиенты подключаются и отключаются.
Я запускаю образец...
493 просмотров
schedule
01.12.2022
Реактивные расширения (Rx) Switch() создают новый наблюдаемый объект, который не подписан на предоставленный OnCompleted()
У меня проблема с моей подпиской Rx с использованием оператора Switch.
_performSearchSubject
.AsObservable()
.Select(_ => PerformQuery())
.Switch()...
265 просмотров
schedule
02.08.2022
Rx: количество сгруппированных событий в движущемся окне
Я начал рассматривать использование реактивных расширений с EventStore. В качестве доказательства концепции я хотел бы посмотреть, смогу ли я заставить Rx потреблять поток событий и выводить количество событий, сгруппированных по типу, в течение...
470 просмотров
schedule
01.02.2023
Представление обновления — Реактивные расширения
У меня есть следующий код:
Observable.Interval(TimeSpan.FromMilliseconds(2500)).SubscribeOn(XXX).ObserveOn(YYY).Subscribe( t => SendCounter(t), e => HandleException(e));
Где XXX, YYY — это Schedulers .
Внутри SendCounter(t) я...
188 просмотров
schedule
11.01.2023
Как получить последнее известное значение IObservable?
Предположим, я создаю редактор изображений с помощью Rx.Net. Пользователь может управлять холстом с помощью мыши. Применяемая манипуляция зависит от выбранного в данный момент инструмента. Например, может быть инструмент «рисовать» и инструмент...
540 просмотров
schedule
01.09.2022
Дросселируйте, но отбросьте результаты, если они пришли слишком поздно
Я пишу пользовательский интерфейс, в котором пользователь может вводить поисковый запрос, а список постоянно обновляется, предлагая предложения.
Моей первой мыслью было то, что примитивная дроссельная заслонка Rx была идеальным вариантом, но она...
289 просмотров
schedule
27.01.2023
Автосохранение с RX в C#
Я хочу реализовать функцию автосохранения. У меня есть два наблюдаемых:
IObservable<Unit> changes : создает элемент каждый раз, когда пользователь редактирует текст
IObservable<Unit> saves : генерирует событие сохранения каждый...
93 просмотров
schedule
27.06.2022
RX.Net: используйте повторную попытку, но регистрируйте любое исключение
Я новичок в RX и занимаюсь обработкой ошибок и использованием Retry; У меня есть следующее (да, я знаю, что это не «настоящий» модульный тест, но он дает мне место для возни!!), и мне было интересно, как мне сохранить повторную попытку, но иметь...
634 просмотров
schedule
03.11.2022
Можно ли попробовать последний элемент в горячем наблюдаемом, сгруппированном по ключу?
Можно ли в Rx.NET отобрать последний элемент в горячем наблюдаемом объекте, сгруппированном по ключу?
Например, если у меня есть IObservable<Price> , где Price :
Price
- Key
- Bid
- Offer
Предположим, что IObservable связан с...
461 просмотров
schedule
27.11.2022
Rx .NET - принудительно излучать буфер
Я хочу использовать функциональность буфера Rx:
var source = new Subject<Price>();
var buffer = source
.Buffer(TimeSpan.FromSeconds(30), 5)
.Where(p => p.Any());
это означает, что выброс (публикация подписчикам) происходит,...
1218 просмотров
schedule
06.07.2023
Rx.Net: вызов нескольких IObservable в SelectMany
Обратите внимание: это продолжение вопроса . выложили ранее но интересующее решение другой ситуации.
Я пытаюсь сделать несколько вызовов методов, каждый из которых возвращает IObservable, но значения, возвращаемые обратно в операторе...
330 просмотров
schedule
11.07.2023
Повторно вызывать реактивную команду, пока условие не будет выполнено
Я использую ReactiveUI для приложения UWP и имею две команды CommandA и CommandB . CommandA при вызове пытается внести изменения в оборудование. CommandB при вызове считывает аппаратное обеспечение и предоставляет последнее значение.
Я...
412 просмотров
schedule
26.09.2022
Уведомление асинхронного субъекта от другого наблюдаемого с использованием Rx .NET
Я пытаюсь уведомить слушателей, которые подписались на Subject _sub из другого наблюдаемого, и после этого записать какое-то сообщение в обработчик Do . Я вызываю OnNext, и все бы работало нормально, если бы _sub не было асинхронным. Проблема...
137 просмотров
schedule
18.02.2024
.NET ReactiveExtensions: используйте Sample() с переменным промежутком времени
Учитывая высокочастотный наблюдаемый поток данных, я хочу испускать элемент только каждые XX секунд.
Обычно это делается в RX с помощью .Sample(TimeSpan.FromSeconds(XX))
Однако... Я хочу, чтобы интервал времени менялся в зависимости от...
70 просмотров
schedule
15.04.2023
Проблема обратного давления в rx.net
Я хотел прочитать строки из файла CSV и использовать RX.Net для некоторых преобразований, и я хотел выполнить пакетное обновление и отправлять обновление каждые 250 миллисекунд.
public static IEnumerable<string> ReadCSV(string filePath)
{...
286 просмотров
schedule
04.04.2023
Рекомбинация элементов из одного и того же реактивного потока
То, чего я хочу достичь, можно описать следующим образом:
У меня есть поток выборок , которые представляют собой значения измерений с отметками времени. Это сырой поток.
Я применяю фильтр к необработанному потоку, в результате чего получаю...
36 просмотров
schedule
27.08.2022
Наблюдается из метода обратного вызова
Допустим, у меня есть класс, который наследует устаревший API и переопределяет виртуальный метод, который вызывается, когда что-то происходит.
type MyClass() as this =
let somethingObservable: IObservable<Something> = ...
override...
67 просмотров
schedule
15.03.2024
Можно ли добавить пользовательское сообщение в оператор Rx.Net Timeout
Я пытаюсь прочитать поток данных с устройства и найти в нем действительные данные. Это набор нулей с некоторыми данными между ними. Что-то типа:
0,0,0,1,2,3,2,1,0,0,0,0,1,2,3,2,1,0,0,0 и так далее.
То, что выдается после обработки, представляет...
47 просмотров
schedule
30.11.2022
Как реализовать оператор ScanAsync с асинхронным аккумулятором в Rx.Net?
Оператор Scan в Rx.Net имеет подпись:
public static IObservable<TAccumulate> Scan<TSource, TAccumulate>(this IObservable<TSource> source, TAccumulate seed, Func<TAccumulate, TSource, TAccumulate> accumulator);...
86 просмотров
schedule
06.08.2022
