system.reactive

8Ciepło

2Odpowiedz

Pobieranie bazy danych z rozszerzeniami reaktywnymi

Muszę wysłać zapytanie do bazy danych w odpowiednim czasie, aby poznać stan istniejącego systemu. Myślałem o opakowaniu kwerendy wokół Observable, ale nie wiem prawidłowy sposób to zrobić. Zasadniczo

c# .net system.reactive reactive-programming 2015-11-14

---

6Ciepło

1Odpowiedz

Czy istnieje sposób deklaratywnego przekazywania aktualizacji do obserwowalnego po zdefiniowaniu?

Eksploruję Rx i chciałem sprawdzić, czy mogę zadeklarować dane wejściowe i z jakiegoś elementu UI względem siebie, zanim ten składnik elementu zostanie zainicjowany. To co to będzie wyglądać: class Vi

system.reactive rx-swift 2016-01-05

---

9Ciepło

2Odpowiedz

Bieg histogram strumień z Rx

Mam następujący pojedynczy strumień list A B C A D B A C D I z tego strumienia, chciałbym strumień uruchomiony Ilość na literę (A,1) (A,1), (B,1) (A,1), (B,1), (C,1) (A,2), (B,1), (C,1)

system.reactive reactive-programming rx-java rxjs 2015-09-29

---

5Ciepło

1Odpowiedz

Custom Rehediler (RX) Custom Scheduler C#

Czy jest możliwe zbudowanie niestandardowego programu planującego, który może sprawdzić wartość każdego elementu przechodzącego przez IObservable, aby zdecydować, który wątek przetworzyć obiekt? Mam w

c# system.reactive 2015-08-28

---

6Ciepło

1Odpowiedz

RxJS - Catch i prowadzić

jestem stara się obsłużyć błędy z Rx w sposób spodziewałem. Kiedy mają widoczny (na przykład ze strumienia click) i wystąpi wyjątek chcę go złapać, ale prowadzić. Wszystkie rozwiązania, które próbował

javascript system.reactive rxjs 2015-05-22

---

5Ciepło

3Odpowiedz

Z rozszerzeniami reaktywnymi (RX), czy możliwe jest dodanie polecenia "Przerwa"?

Mam klasę, która bierze strumień wydarzeń i wypycha inny strumień wydarzeń. Wszystkie zdarzenia używają rozszerzeń reaktywnych (RX). Przychodzący strumień zdarzeń jest wypychany z zewnętrznego źródła

c# .net system.reactive reactive-programming rx.net 2015-07-11

---

13Ciepło

1Odpowiedz

Jak działają funkcje RxJava doOnError i onErrorReturn?

zrobiłem te testy jednostkowe, a wynik nie jest to, czego się spodziewałem w ogóle: // This one outputs "subscribe.onError" @Test public void observable_doOnError_subscribingToError() throws Interru

java system.reactive rx-java 2015-09-02

---

5Ciepło

1Odpowiedz

Dlaczego Task.henAny nie rzuca oczekiwany TimeoutException?

Proszę zauważyć następujący kod trywialny: class Program { static void Main() { var sw = new Stopwatch(); sw.Start(); try { Task.WhenAny(RunAsync()).GetAwaite

c# .net async-await task-parallel-library system.reactive 2015-07-21

---

5Ciepło

2Odpowiedz

Token anulowania dla obserwowalnego

Jak mogę anulować następujący typ obserwowanego Rx, jeśli następujące obserwowalne jest tworzone na przycisku StartButton, tj. Z przycisku zatrzymania. var instance = ThreadPoolScheduler.Instance; O

c# system.reactive 2016-02-12

---

12Ciepło

1Odpowiedz

Dlaczego to obserwowalne. Generowanie przeciążenia powoduje wyciek pamięci? [Używanie Timespan <15ms]

Następujący kod Rx.NET zużyje około 500 MB pamięci po około 10 sekundach na moim komputerze. var stream = Observable.Range(0, 10000) .SelectMany(i => Observable.Generate( 0,

c# system.reactive 2015-09-17

---