Результаты поиска по запросу "system.reactive"
Что определенно не является хвостовой рекурсивностью. Я думаю, что если вы можете сделать его хвост рекурсивным, то это, вероятно, решит вашу проблему
аюсь придумать Rx Builder для использования Reactive Extension в синтаксисе выражения вычисления F #. Как я могу это исправить, чтобы он не взорвал стек? Как пример Seq ниже. И есть ли планы предоставить реализацию RxBuilder как часть Reactive ...
Предварительный исторический поток и прямой эфир в Rx
У меня есть горячая наблюдаемая, которую я обычно реализую, используя обычныйSubject внизу, чтобы заинтересованные могли подписаться на прямой поток уведомлений. Теперь я хотел бы сохранить этот живой поток, но также показать исторический поток ...
Проблема с кэшированием в WebClient / HttpClient
Я разрабатываю код для опроса биржи Bitstamp каждые 30 секунд. Это код, который я имею: public IObservable<string> Stream(Uri way, WebClient wc) { Func<IObserver<string>, Task> Fun = async Observer => { var res = ...
Когда вы будете использовать Rx
айт MVC 3 с некоторыми разделами в Silverlight 5 Можно ли использовать Rx в этом сценарии?Если да, то как и какие компоненты приложения могут принести пользу
Видимо новый синтаксис немного изменился. Текущий синтаксис следующий:
есть клиент, вызывающий очередь TIBCO EMS, и мы подготавливаем события следующим образом: var msgConsumer = _session.CreateConsumer(responseQueue); var response = Observable.FromEvent<EMSMessageHandler,EMSMessageEventArgs> (h ...
Приятно! Это кажется проще, я буду использовать это отныне.
аюсь пройти учебный курс Дана Салливана по Rx Extensions на PluralSight. Это отличный материал, но, к сожалению, Rx, похоже, уже изменился, хотя курс был опубликован только месяц назад. Большинство изменений тривиально отработать (перейти с трех ...
Ричард пропустил критическое предположение, что ваша функция StartWork имеет подпись «IObservable <SomeResult> StartWork (элемент QueueItem)» - перегрузка слияния, которую вы ищете, работает только с IObservable <IObservable <T >>
несколько статей по этому вопросу, и у меня это работает ... но я хочу знать, как установить максимальное количество потоков задач для моих подписок Observable одновременно. У меня есть следующее, чтобы распараллелить асинхронное сохранение ...
Обрабатывать множество небольших задач и поддерживать отзывчивость интерфейса
У меня есть приложение WPF, которое должно выполнить некоторые небольшие задачи. Все эти небольшие задачи создаются одновременно и добавляются в очередь диспетчера с приоритетом Normal. Одновременно отображается индикатор занятости. В результате ...
работал для моей ситуации.
инаю работать со структурой ReactiveUI в проекте Silverlight и мне нужна помощь в работе с ReactiveCommands. В моей модели представления у меня есть что-то, что выглядит примерно так (это просто упрощенный пример): public class MyViewModel : ...
ObserveOn и SubscribeOn - где работа выполняется
Основываясь на прочтении этого вопроса:В чем разница между SubscribeOn и ObserveOn [https://stackoverflow.com/questions/7579237/whats-the-difference-between-subscribeon-and-observeon] ObserveOn устанавливает, где код находится вSubscribe ...