system.reactive

5Ciepło

2Odpowiedz

Bufor Rx bez pustych połączeń z subskrybentem

W mojej aplikacji WPF przy użyciu .Net 4.6 Mam zdarzenie, które uruchamia nowe punkty danych z wysoką szybkością (kilkaset na sekundę), ale nie cały czas. Te dane są wyświetlane na wykresie. Chciałbym

c# buffer system.reactive batching 2016-02-24

---

9Ciepło

1Odpowiedz

Czy istnieje Rx.NET dla .NET Core?

Znaleziono https://github.com/Reactive-Extensions/Rx.NET/issues/148, ale nie mogłem dowiedzieć się dolnej linii - gdzie jest Rx.NET dla .NET Core i jak go zdobyć? Używam oprogramowania Enterprise Visu

c# system.reactive .net-core 2016-07-26

---

6Ciepło

2Odpowiedz

Dlaczego RefCount nie działa po rozłączeniu wszystkich początkowych subskrybentów?

Rozważmy następujący: [Fact] public void foo() { var result = new Subject<bool>(); var startCount = 0; var completionCount = 0; var obs = Observable .Defer(() => {

c# .net system.reactive 2016-02-29

---

6Ciepło

4Odpowiedz

Handling nadciśnieniem w Rx.NET bez onBackpressureLatest

muszę wdrożyć następujący algorytm w Rx.NET: Take ostatnią pozycję z stream, lub czekać na nowego elementu bez blokowania, jeśli nie ma żadnych nowych elementów . Tylko ostatni przedmiot ma znaczenie,

c# f# system.reactive reactive-programming 2017-02-14

---

7Ciepło

1Odpowiedz

Jak hermetyzacji tworzenie długich reaktywnych łańcuchów obserwabli

Obecnie mam następujący fragment kodu Rx/ReactiveUI: this.WhenAnyValue(x => x.Listras) .Where(item => item != null) .Throttle(TimeSpan.FromMilliseconds(millis)) .ObserveOn(TaskPo

c# system.reactive fluent reactiveui 2017-07-17

---

5Ciepło

1Odpowiedz

Czy istnieje operator if/then/else dla obserwowalnych w języku C# dostępny?

Czy ktoś wie o odpowiednim zamienniku dla tego handmade jeśli/then/else operator dla reaktywnych rozszerzeń (.Net/C#)? public static IObservable<TResult> If<TSource, TResult>( this IObservable<TSo

c# .net system.reactive 2017-04-11

---

5Ciepło

3Odpowiedz

Rx przedstawia operatora z pierwszym i ostatnim numerem

Czy istnieje jakaś kombinacja operatorów rx, aby uzyskać pierwsze i ostatnie zdekonferencje? Będzie to używane w scenariuszach szczegółów głównych (lub nawet w scenariuszach), w których chcemy natychm

javascript angular system.reactive rxjs 2016-03-12

---

7Ciepło

1Odpowiedz

RxJava: Jak warunkowo zastosować operatorów do obserwowalnego bez zerwania łańcucha

Mam łańcuch operatorów na RxJava obserwowalne. Chciałbym móc zastosować jednego z dwóch operatorów w zależności od wartości boolowskiej bez "zerwania łańcucha". Jestem stosunkowo nowy w Rx (Java) i wy

java android system.reactive rx-java 2016-03-17

---

5Ciepło

1Odpowiedz

Niestandardowy operator Rx do dławienia tylko wtedy, gdy pojawiła się ostatnia wartość

Próbuję utworzyć operator Rx, który wydaje się całkiem przydatny, ale nieoczekiwanie nie znalazłem żadnych pytań na temat Stackoverflow, które pasują dokładnie. Chciałbym stworzyć odmianę na Throttle,

c# system.reactive 2017-03-03

---

7Ciepło

1Odpowiedz

PCL WeakEventManager z rozszerzeń reaktywnych wywołuje zdarzenie w ciągu 3 - 7 minut

Próbuję zaimplementować WeakEventManager w PCL za pomocą biblioteki reaktywnej. Chodzi o to, że zachowuje słabe odniesienie dla subskrybenta i za każdym razem, gdy zdarzenie się uruchamia - pobiera de

c# memory-leaks system.reactive weak-references weak-events 2016-11-29

---