Свързани въпроси 'system.reactive'

Не може да се отпише от Rx
Фон Пиша софтуер, който прави следното: Потребителят кликва върху „старт“. Стартира се задача, която изпълнява някаква работа и стартира събития за актуализиране на GUI. Наблюдаваното използва събитията от задачата и отпечатва данни в...
769 изгледи

Как Async потоците се сравняват с реактивното разширение?
Как да сравним следните две? Rx по-мощен ли е? Реактивно разширение: var observable = Observable.Create<char>(async (observer, cancel) => { while (true) { string line = await sr.ReadLineAsync(); if (line ==...
2704 изгледи

BehaviourSubject и CombineLatest - Странно поведение
Като се има предвид следният код. EventLoopScheduler scheduler = new EventLoopScheduler(ts => new Thread(ts)); BehaviorSubject<int> subject = new BehaviorSubject<int>(0); subject .ObserveOn(scheduler)...
352 изгледи
schedule 11.10.2022

Http запитване, докато заявката не бъде изпълнена с Rx
Искам ресурс през http от спокоен api. Ресурсът отнема време, за да достигне състояние „завършен“ и отговорният http код на състоянието отразява пълнотата на ресурса. Извикващият клиент е потребител, чакащ да консумира ресурса, който не иска да...
612 изгледи

Създаване на наблюдаема, която правилно изпраща грешки?
Уча Rx и работя върху част от семантиката. Като експеримент изграждам наблюдаем таймер, който извиква OnError на десетия тик. Досега имам 2 метода, които смятам, че показват идентично поведение: var timer =...
181 изгледи
schedule 04.11.2022

RX2.0: ObjectDisposedException след премахване на EventLoopScheduler
Наскоро пренесохме системата от RX 1.11111 към RX 2.0 и открихме този проблем. Използваме EventLoopScheduler за ObserveOn по следния начин: IDisposable subscription = someSubject .ObserveOn(m_eventLoopScheduler) .SomeMoreRXFunctions()...
1184 изгледи
schedule 10.12.2022

Работи ли Subject.Subscribe само в статичен екземпляр (или пропускам нещо)
Бъркам с реактивни разширения и попаднах на камък, който не мога да разбера каква е причината за живота си. Ако използвам приложение за конзолен режим .NET 4, където всичко е статично, както следва: using System; using...
94 изгледи

ObservableCollections, използващи Rx с APE/Reverse Ajax - Избутване от сървъра
Просто се чудя дали има често използван метод за уведомяване на абонати (javascript клиенти) за наблюдавани колекции (Rx/Knockout.js) за промени от страна на сървъра. Бих искал да имам обект, който извършва двупосочно свързване на данни на живо...
656 изгледи

Защо името Behavior в BehaviorSubject в RX?
Любопитен съм, защо мислите, че са използвали името „Поведение“ за обекта BehaviorSuject в Ractive Extensions? забележка: обект на поведение връща последната стойност (или init vaue) като първа стойност на всеки абонат.
1577 изгледи
schedule 01.12.2023

Как да комбинирате бавно движеща се наблюдаема с най-новата стойност на бързо движеща се наблюдаема
Един приятел ме попита това - реших, че е добър въпрос, затова го публикувам отново и отговора ми тук: Имам тези два потока: var slowSource = Observable.Interval(TimeSpan.FromSeconds(1)); var fastSource =...
275 изгледи
schedule 01.12.2022

Има ли начин да чуете, че няма събития, които се повдигат в Reactive Extensions?
Имам изискване да изключа определена функция , когато потребителят започне да въвежда, което е просто. И когато потребителят спре да въвежда, искам да включа функцията отново. Без реактивни разширения човек може просто да приложи тази функция с...
265 изгледи

Отчаяно се нуждая от помощ в Rx.Net
Здравейте момчета, аз съм много много нов в Rx и се опитвам да събера просто тестово приложение. Той основно се абонира за събитието за щракване на прозореца с помощта на Rx и задава текста в текстово поле на „Щракнато“. Това е wpf приложение. Ето...
1104 изгледи
schedule 19.12.2023

Странен сценарий с Observable, който кара наблюдателите да пропускат елементи в OnNext
Имам приложение, което следи колебанията в цената на млякото по щати, потребителите, когато видят цената на млякото в местния магазин за хранителни стоки, могат да отидат на уебсайт и да изпратят тази цена (подобно на GasBuddy). Когато изпратят...
105 изгледи

Комбинирайте припокриващи се наблюдавани потоци, но вземете най-новите стойности
Имам случай на употреба, който се опитвам да овладея по отношение на комбинирането на потоци с помощта на Rx. Имам 3 потока, извеждащи стойности: S1: ----1----2----3----4----5-----6 S2: ----a---------c---------d------ S3:...
72 изгледи
schedule 26.11.2022

Рекурсия и Rx паралелизъм
Докато се опитвах да обходя ефективно дървото на директориите, опитах RX решение, описано тук . Въпреки че това решение работи за малка дълбочина на дърво, то не може да се използва за голяма дълбочина на дърво. Планировчикът по подразбиране...
779 изгледи

Реактивни разширения, ключалки и резби
Използвам реактивни разширения, за да работя с потребителски интерфейс на wpf, като цяло имам текстово поле, от което се нуждая, за да правя както вземане на проби, така и регулиране (правейки някои неща непрекъснато, докато пишете, и някои неща,...
1623 изгледи
schedule 07.02.2024

С Reactive Extensions (RX) възможно ли е да добавите команда за пауза?
Имам клас, който приема поток от събития и изтласква друг поток от събития. Всички събития използват реактивни разширения (RX). Входящият поток от събития се изтласква от външен източник към IObserver<T> с помощта на .OnNext , а...
2401 изгледи

Имаме ли нужда от сборките Rx System.Reactive.*?
Тези дни се опитвах да програмирам с Rx . Сега всеки път, когато започвам програмирането с него, стигам до въпроса дали наистина имам нужда от външни SDK библиотеки като System.Reactive.* сборки. Както винаги, искам да програмирам с помощта на...
77 изгледи

С Rx, как да игнорирам всички освен най-новата стойност, когато моят метод Subscribe се изпълнява
Използвайки Reactive Extensions , искам да игнорирам съобщенията, идващи от моя поток от събития, които се появяват, докато моят Subscribe метод работи. т.е. понякога ми отнема повече време, за да обработя съобщение, отколкото времето между...
7586 изгледи
schedule 23.02.2024

Rx 2.1: Как да се абонирате и да наблюдавате правилно в Dispatcher
Първо, използвам най-новия Rx, който е 2.1. Доколкото разбирам, много неща са се променили, когато Rx навърши 2 години, така че наистина очаквам с нетърпение да получа актуален отговор. Благодаря предварително. Изпълнявам класическа задача за Rx:...
3221 изгледи