system.reactive

18Ciepło

2Odpowiedz

oczekiwanie na obserwowalne

Tak więc w czasie smutnych dni w C# 4.0 stworzyłem następującą klasę "WorkflowExecutor", która zezwoliła na asynchroniczne przepływy pracy w wątku GUI, włamując się do kontynuacji IEnumerable "return

c# system.reactive async-await .net-4.5 c#-5.0 2012-04-24

---

7Ciepło

1Odpowiedz

Ograniczanie/ustawianie zdarzeń - Rozszerzenia reaktywne?

Chciałbym wprowadzić pewne ograniczające działanie do jednej z moich modeli widoku. Jest to aplikacja silverlight, ale nie sądzę, że jest to szczególnie ważne. Rozważmy klasę z trzech właściwości: Pro

c# .net system.reactive silverlight-5.0 2012-06-15

---

7Ciepło

2Odpowiedz

Obserwowalna analiza IO sieci

Próbuję użyć Rx do odczytu ze strumienia odbierającego TCPClient i przeanalizowania danych do IObservable z łańcucha, rozdzielonego przez znak nowej linii "\ r \ n" Poniżej znajduje się sposób odbiera

c# system.reactive 2012-05-01

---

5Ciepło

3Odpowiedz

używać RX do uruchamiania wydarzeń w różnym czasie?

Mam dużą kolekcję prostej klasy pary: public class Pair { public DateTime Timestamp; public double Value; } Oni są klasyfikowane według datownik rosnącym. Chcę wywołać zdarzenie z wartością (powiedz

c# multithreading system.reactive 2012-05-03

---

9Ciepło

3Odpowiedz

Używanie IObservable zamiast zdarzeń

Ostatnio czytałem o IObservable. Do tej pory przyglądałem się różnym pytaniom na SO i oglądałem wideo na temat tego, co mogą zrobić. Cały myślący mechanizm "pchania" jest genialny, ale wciąż próbuję z

c# events system.reactive 2012-06-25

---

12Ciepło

1Odpowiedz

TPL Dataflow i Rx Łączony przykład

Chcę tylko nauczyć się obu i jak z nich korzystać. Rozumiem, że mogą się wzajemnie uzupełniać, ale nie mogłem znaleźć przykładu kogoś, kto faktycznie to robi.

.net task-parallel-library system.reactive c#-5.0 tpl-dataflow 2012-07-08

---

17Ciepło

4Odpowiedz

Czy powinienem wystawiać IObservable <T> na moich interfejsach?

Mój kolega i ja mamy spór. Piszemy aplikację .NET, która przetwarza ogromne ilości danych. Odbiera elementy danych, grupuje je podzbiorami na bloki według pewnego kryterium i przetwarza te bloki. Załó

c# .net system.reactive 2012-07-09

---

13Ciepło

2Odpowiedz

Observable.Defer - potrzebuję wyjaśnienia, co dokładnie robi

Powiedz, że chcę generować asynchroniczny strumień liczb losowych, który wypompowuje nową wartość co 100 milisekund. Starając się wymyślić rozwiązanie, moja pierwsza próba wyglądała mniej więcej tak:

c# .net system.reactive 2012-07-12

---

10Ciepło

3Odpowiedz

Rozszerzenia reaktywne: Przetwarzaj zdarzenia w partiach + dodaj opóźnienie między każdą serią

Mam aplikację, która w niektórych punktach podnosi prawie 1000 zdarzeń w tym samym czasie. To, co chciałbym zrobić, to wsadowe zdarzenia do partii 50 elementów i rozpoczynanie ich przetwarzania co 10

c# system.reactive windows-runtime 2012-06-07

---

28Ciepło

8Odpowiedz

W przypadku Rx, jak zignorować wszystkie-z wyjątkiem-najnowszą wartość, gdy moja metoda subskrypcji jest uruchomiony

, przy użyciu Reactive Extensions, chcę zignorować wiadomości pochodzących z mojego strumienia zdarzeń, które występują podczas, gdy moja metoda Subscribe jest uruchomiony. To znaczy. Czasami zajmuje

c# system.reactive 2012-06-13

---