rx-android

6Hitze

3Antwort

Ich möchte meine beobachtbar wie if/else Aussage So etwas spalten: A[] array = new A[10]; for (int i = 0; i < array.length; i++) { array[i] = new A(getRandomString(), getRandomInt()); } Obser

2Hitze

2Antwort

Automatisches Abrufen von Objekten aus beobachtbaren Objekten, wenn ein Ereignis ohne Ereignisbus ausgelöst wird

Was ist der beste Weg, um neue Objekte automatisch von einer Observablen abzurufen, wenn Sie ein externes Ereignis haben, das Ihnen sagt, dass Sie dies tun sollten? Zum Beispiel kann sagen, ich habe u

3Hitze

2Antwort

RxAndroid: Observable.first() gibt die Liste der Null-Objekte zurück

Nach diesem tutorial habe ich zwei Quellen zum Abrufen von Daten erstellt. Ich erwarte, dass, wenn es keine Daten lokal gibt, ich Netzwerkanfrage senden werde. Aber die ganze Zeit erhalten Sie eine Li

0Hitze

2Antwort

Wie teilt man eine erstellte Observable?

Ich habe eine Observable erstellt, die die ViewPager's positionOffset emittiert. public Observable<Float> observable() { return Observable.create(new Observable.OnSubscribe<Float>() { @Ov

5Hitze

1Antwort

Filterliste von Objekt in Rxjava

I List<Object> basierend auf Abfrage von Benutzern filtern möge und dann wieder List<Object> er/gefunden her.I, wie Elemente filtern Aber das Problem ist, ich weiß nicht, wie List<Object> zurück. Ich

4Hitze

1Antwort

Zip scheint nicht auf Observable zu warten, um Daten auszugeben

Ich versuche, zwei parallele Anfragen mit Volley zu führen, um eine Datenbank zu aktualisieren (mit DBFlow). Eine Tabelle in der DB kann nur einmal ausgefüllt werden, wenn beide Anfragen gemacht und i

0Hitze

1Antwort

Löscht die Abmelde-Methode in Rx nur den letzten Abonnenten oder stoppt die Ereignisbuchung für den gesamten Stream?

Ich bin interessant, wie Rx die Subskriptions # abmelden Methode behandelt. Zum Beispiel haben wir Subscription subscription = Observable.from(veryBigList) .map(value -> convertValue(value))

0Hitze

2Antwort

Mehrere API-Aufrufe Objekt

Sagen sie, zum Beispiel zu schaffen, habe ich eine Klasse hatte: public class NI { private int id; @SerializedName("date") private String created_at; private String slug; pri

4Hitze

2Antwort

Wie kann ich diesen rxjava zip parallel laufen lassen?

Ich habe eine Schlafmethode, um einen lang laufenden Prozess zu simulieren. private void sleep() { try { Thread.sleep(2000); } catch (InterruptedException e) { e.printStackTrace(

0Hitze

3Antwort

Limit-Aktionen mit rxJava und retryWhen Betreiber

Meine Anwendung muss in der Regel zwei Dinge tun: nur eine Netzwerkanfrage zur gleichen Zeit Accept Retry wenn Anfrage fehlgeschlagen Das ist, wie ich Implementieren Sie es: public class RequestsLocke