reactivex

Fragen
ReactiveX ist eine Bibliothek zum Erstellen asynchroner und ereignisbasierter Programme mithilfe von beobachtbaren Sequenzen.
3
Antworten

Wie kann ich Observable in RxJS vervollständigen?

Nehmen wir an, wir haben ein Observable : %Vor% Wie kann ich Abgeschlossen festlegen (was löst das Ereignis onComplete für alle abonnierten Beobachter aus)?     
04.12.2015, 20:47
1
Antwort

RxJava 2.0 - So konvertieren Sie Observable zu Publisher

Wie konvertiert man Observable in RxJava Version 2 in Publisher? In der ersten Version haben wir das Projekt Ссылка , das genau das tut, was ich brauche. Aber wie kann ich es in RxJava 2 machen?     
29.11.2016, 23:11
2
Antworten

RXJS: Aggregierte Debounce

Mein Anwendungsfall ist wie folgt: Ich bekomme Ereignisse, die manchmal in Bursts passieren. Wenn ein Burst auftritt, muss ich nur einmal damit umgehen. Debounce macht das. Aber Entprellen gibt mir nur das letzte Element eines Bursts, aber ic...
01.03.2016, 10:23
3
Antworten

Einzel vs Observable in Java RX

In der neuen Version führte reactiveX Single als eine Variante von Observable ein Ссылка Das ist nett zu haben, da ich in meinem aktuellen Anwendungsfall mehrere Ausführungen habe und jeder von ihnen nur ein einziges Ergebnis liefert. Es wi...
30.03.2016, 16:08
2
Antworten

RxJava verschmelzen entprellte und nicht entlarvte Observablen

Ich habe zwei Observable: Observable O (open): Datei mit einigen Inhalten in textview geöffnet Beobachtbare E (edit): Datei Inhalt in Textansicht bearbeitet Ich möchte E beobachtbar machen und es mit O beobachtbar verbinden. %Vor% D...
21.09.2016, 17:18
2
Antworten

Wie kann ich den zeitgesteuerten Gegendruck in RxJS5 anwenden?

Stellen Sie sich vor, ich habe den folgenden Code: %Vor% Dies gibt sofort die Ergebnisse aus. Nun, wie stelle ich eine zeitgesteuerte Verzögerung zwischen jeder Nachricht als Art des Gegendrucks (beachten Sie, dass ich keinen Puffer will;...
29.01.2018, 03:23
3
Antworten

Warum gibt mein RxJava Observable nicht aus oder vervollständigt es nur, wenn es blockiert?

Hintergrund Ich habe eine Reihe von RxJava Observables (entweder von Jersey Kunden oder Stubs mit Observable.just(someObject) ) generiert. Alle sollten genau einen Wert ausgeben. Ich habe einen Komponententest, der alle Jersey-Kunden ausspi...
13.12.2015, 23:21