Интересно, как лучше всего получить последний элемент в последовательности до того, как сработает тайм-аут? У меня есть код, который время от времени пингует удаленные сервисы, и я хочу иметь возможность идентифицировать тот, который отключился....

Я хочу создать последовательность, которая объединяет одну или несколько последовательностей, созданных динамически (во время выполнения). Я пробовал с mySequence = mySequence.Concat(anotherSequence) , но это прерывает текущие подписки на...

Я хочу добавить дополнительный «закрывающий» элемент к моей наблюдаемой последовательности. Есть ли расширение Reactive LINQ, похожее на StartWith , но для конца наблюдаемой последовательности? Вот приближение того, что я хочу, хотя последний...

У меня есть прокси-сервер, который вызывает несколько REST API для создания детализированного вывода курса для пользовательского интерфейса. Пользовательский интерфейс построен с помощью KnockoutJS. Я использую методы tasks/async для асинхронного...

У меня есть цепочка блоков потока данных TPL, и я хотел бы наблюдать за прогрессом где-то внутри системы. Я знаю, что могу просто вставить TransformBlock в меш, где я хочу наблюдать, заставить его опубликовать в каком-нибудь средстве обновления...

Как наблюдать изменения свойств на любом подуровне дерева? Рассмотрим, например, класс TreeNode со свойствами Name и ChildNodes . Как наблюдать изменения Name на любом подуровне TreeNode ? Использование может выглядеть примерно так:...

Я с радостью делал некоторые вызовы API в приложении WPF, используя RX, следующим образом: IDisposable disposable = _textFromEventPatternStream .ObserveOn(_rxConcurrencyService.Dispatcher) .Subscribe(async input =>...

У меня есть две горячие наблюдаемые, которые я не хочу пропустить ни одного уведомления 1-я наблюдаемая дает числа 1-2-3-4 и 2-я струны a-b Я ищу способ заархивировать их для получения следующего вывода a-1 b-2...

Цель состоит в том, чтобы выполнить некоторую асинхронную работу с дефицитным ресурсом в операторе RX, например, Select. Проблемы возникают, когда наблюдаемые уведомления приходят со скоростью, превышающей время, необходимое для завершения...

У меня есть один наблюдаемый объект, для которого я использую GroupBy , чтобы получить несколько потоков. На самом деле мне нужен результат Scan для каждого подпотока. Предположим, что наблюдаемая величина — это цены на продукты, а результатом...

На данный момент у Rx.Net нет эквивалента concatMap, но наверняка есть способ получить аналогичное поведение с учетом доступной функциональности. У меня сейчас есть observable.SelectMany(x => ProcessItemAsync(item).ToObservable()) , где...

Я делаю свой первый прыжок в мир Rx, и мне трудно получить желаемые результаты, особенно с оператором GroupBy, поэтому любая помощь будет очень признательна. Как я могу подписать нескольких наблюдателей на определенную группу? Мои требования: У...

В различных случаях мне хотелось иметь оператор Rx Replay , который буферизует входящие уведомления, синхронно воспроизводит свой буфер, когда он подписывается в первый раз, и после этого останавливает буферизацию. Этот облегченный оператор...

Ниже приведен следующий код: public class FooService { private ITransportService _transportService; public FooService(ITransportService transportService) { _transportService = transportService;...