reactive-programming

3Hitze

1Antwort

`sample` wird ausgelöst, wenn sie abgeschlossen ist. Wie vermeide ich?

let stream = PublishSubject<Int>() let trigger = PublishSubject<Void>() stream.sample(trigger).subscribeNext { value in print("value \(value)") } stream.onNext(5) trigger.onCompleted() Das obi

0Hitze

1Antwort

Wie Push-Ansicht in Tabbar für Android in ReactNative

Ich habe folgenden Code mit Registerkarte Zwei, ich habe eine View1.js Seite und View2.js Seite. Ich möchte diese View1 und View2 in Tab-Leiste schieben. Hier ist mein Code. import React, { AppRegist

0Hitze

1Antwort

updateComponent - React

Ich stöbere durch das React Repository auf Github und während ich Lifecycle-Funktionen durchsuche, habe ich folgendes gefunden: updateComponent: SpecPolicy.OVERRIDE_BASE. Es zeigt den beabsichtigten A

8Hitze

1Antwort

Wie werden zwei Ereignisströme auf einer gemeinsamen Ereigniseigenschaft verknüpft?

Betrachten Sie die folgenden zwei Ereignisströme. Jedes Ereignis hat eine Eigenschaft timestamp/ts und value. Ich mag diese beiden Ströme kombinieren, wo die Ereignisse die gleichen Zeitstempel haben,

1Hitze

2Antwort

Einen Timer/eine Verzögerung in RX anhalten/fortsetzen

Ich versuche, einen verzögerten Vorgang unter Verwendung rx-Java anzuhalten/fortzusetzen, und überraschenderweise kann ich keine Details finden, wie man das macht. Offensichtlich weiß ich, wie man es

2Hitze

1Antwort

Wie lange dauerte es, ein Observable mit RxJava (ReactiveX) zu starten?

Ich benutze Java ReactiveX (RxJava) in Scala Play Framework 2.5 asynchron mit couchbase zu kommunizieren Ich würde gerne wissen, wie lange es dauerte, bis meine Observable ausgeführt wurde? Ich defini

3Hitze

2Antwort

RxJS: Übergabefehler in cycle.js benutzerdefinierten Treiber

Ich habe einige Fehlerbehandlungscode in meiner main Funktion wie folgt implementiert. Es verwendet den Operator catch, um Fehler in einem Stream zu filtern und zu melden und sie in einem anderen zu i

6Hitze

2Antwort

So behandeln Sie Netzwerkfehler in React-Native, wenn das Netzwerk ausgeschaltet ist

So behandeln Sie Netzwerkfehler in React-Native, wenn Gerät nicht mit dem Netzwerk verbunden ist. Mein Szenario ist versuchen, einige API zu verbinden, während Anforderung abrufen, wenn das Netzwerk g

1Hitze

1Antwort

Wie junit diese beobachtbaren async Methode

Ich habe Repo, die eine Asynchron-Ausführung mit java8 und Blindtests: Schnittstelle von zadd: Observable<Long> zadd(K key, double score, V member); public class TargetClass() { .. public v

1Hitze

1Antwort

Gibt es einen Rx-Operator wie groupBy, der nur aufeinanderfolgende Elemente gruppiert?

Ich möchte eine GroupBy, die jedes Mal, wenn sich der Schlüssel ändert, eine neue Observable aussendet. Gibt es so etwas? So etwas wie diese Pseudo-Code: [1,3,5,2,4,3,7] groupByConsecutive? oddEven