system.reactive

3Hitze

3Antwort

Rx, wie Observables zusammengeführt werden und nur feuern, wenn alle in einem bestimmten Zeitrahmen zur Verfügung gestellt werden

Ich habe eine Reihe von beobachtbaren Ereignisströmen, die alle Ereignisse mit Zeitstempeln bereitstellen. Ich interessiere mich nicht für die Ereignisse einzeln, ich muss wissen, wann sie alle innerh

system.reactive rxjs observable 2016-07-26

---

0Hitze

2Antwort

Puffer ausgewählte Nachrichten mit variabler Zeitüberschreitung

Ich habe einen Strom mit Buchstaben (A-Z) und Zahlen (1-9). Ich möchte Briefe, die innerhalb eines Timeouts eingehen (dies kann sich ändern), zusammenfügen und immer sofort Nummern ausgeben. Können Si

c# system.reactive 2016-07-26

---

0Hitze

2Antwort

Wie über mehrere Arrays ohne verschachtelte Observables iterieren

Ich muss über Array iterieren, finden Sie entsprechende Objekte in anderen Array und führen Sie das Ergebnis in einem Objekt zusammen. Angenommen ich drei Arrays var users = [ { name: "A", type:

system.reactive rxjs rxjs5 2016-07-27

---

0Hitze

1Antwort

Anpassbare Filterung auf einem Strom

Ich brauche eine Liste von Filtern auf einem Stream zu konfigurieren. Der Strom zunächst hat keine Filter, aber es hat eine Liste der aktiven Filter während der Zeit. wird jeder Filter eine strenge Gü

c# functional-programming system.reactive reactive-programming 2016-07-29

---

0Hitze

1Antwort

Wie erhalten Sie die Anzahl der Objekte in einem beobachtbaren Stream, ohne sich selbst zu halten?

Wie bekomme ich die Anzahl der Schüler in dieser Schule zu einem bestimmten Zeitpunkt mit dem Rx-Idiom und ohne Status in der School Klasse selbst zu pflegen? using System; using System.Reactive.Subj

c# system.reactive 2016-07-30

---

3Hitze

1Antwort

Covariant Zuordnung funktioniert nicht

Ich versuche, die Benachrichtigung über Änderungen an den Eigenschaften eines Objekts über eine IObservable<T> zu verallgemeinern, aber das ist neben dem Punkt der Frage. Der Punkt der Frage ist: die

c# .net system.reactive 2016-08-01

---

1Hitze

2Antwort

Integration mit Event, bei dem die Delegierten mehr als ein Argument hat und es gibt keine EventArgs

Es gibt keine Überlastung der FromEvent oder FromEventPattern Methoden zu sein scheint, die TDelegate nur in eine IObservable<T> ein Ereignis mit dem Typ konvertieren, wo es mehr als eins Parameter un

c# system.reactive 2016-08-03

---

1Hitze

1Antwort

Gruppieren von Array-Elementen in Rx

Ich möchte die folgende Implementierung in eine mehr deklarative Ansatz bereinigen, hoffentlich gibt es einen Rx-Operator, der mir fehlt. Ich habe ein Array von Daten auf einem Stream veröffentlicht,

c# .net system.reactive reactive-programming 2016-08-04

---

1Hitze

1Antwort

Wie heißt OnNext in Scala rx

Ich versuche zu verstehen, wie beobachtbar funktioniert. Hier ist mein Code. def make: Stream[Int] = { Stream.cons(scala.util.Random.nextInt(10), { println("Making ..") Thread.sleep(1

scala system.reactive reactive-programming 2016-08-08

---

0Hitze

1Antwort

Anfrage/Antwort mit Streams

Ich habe einen Input-Stream von einem RS-232-Port und eine Warteschlange von Befehlen an den seriellen Port mit Rx-Streams. Ich habe meinen Code vereinfacht wie folgt: void Init() { SerialPort s

c# functional-programming system.reactive 2016-08-09

---