Suchergebnisse für Anfrage "rx-java"
Wie kann eine JSON-Antwort bei Verwendung von Retrofit analysiert werden, wenn die Antwort manchmal ein Objekt und manchmal ein Array ist?
Ich verwende Retrofit, um eine JSON-Antwort zu erhalten. Hier sind Teile meiner Implementierung - @GET("/api/report/list") Observable<Bills> listBill(@Query("employee_id") String employeeID);und die Klasse Rechnungen ist - public static class ...
rxJava Schedulers Anwendungsfälle
n RxJava gibt es 5 verschiedene Scheduler [http://reactivex.io/RxJava/javadoc/rx/schedulers/Schedulers.html] wählen von sofortig(: Erstellt einen Scheduler und gibt diesen zurück, der die Arbeit sofort für den aktuellen Thread ...
Firebase offline no CompletionListener on setValue
Ich habe diese Codebasis, in der ich einen Wert festgelegt habe. Im Offlinemodus wird erfolgreich geschrieben, aber die CompletionListener.onComplete-Rückruffunktion wird nicht aufgerufen. newOrderRef.setValue(order, (firebaseError, firebase) -> ...
RxJava- Ist cache () dasselbe wie replay ()?
Ich habe mich gefragt, ob es ein @ gcache() -Operator, der x Anzahl von Emissionen zwischenspeichern, sie aber auch nach einem bestimmten Zeitintervall (z. B. 1 Minute) verfallen lassen könnte. Ich suchte nach etwas wie ...
Wie bekomme ich die Request-URL in Retrofit 2.0 mit rxjava?
Ich versuche, auf Retrofit 2.0 zu aktualisieren und RxJava in mein Android-Projekt aufzunehmen. Ich mache einen API-Aufruf und möchte die URL und die Antwortdaten in SQLite als Cache abrufen. Observable<MyResponseObject> apiCall(@Body body);Und ...
Kartesisches Produkt in RxJava
Ist es möglich, ein kartesisches Produkt von zwei Observablen in rxjava zu erhalten? Etwas wie das: A -> 1,2,3 B -> a,b A x B -> (1, a), (1, b), (2, a), (2, b), (3, a), (3, b)
Wie implementiere ich observLatestOn in RxJava (RxScala)?
Ich versuche das @ zu implementier ObserveLatestOn [https://social.msdn.microsoft.com/Forums/en-US/bbcc1af9-64b4-456b-9038-a540cb5f5de5/how-do-i-ignore-allexceptthelatest-value-when-my-subscribe-method-is-running?forum=rx>] Operator in RxJava ...
RxJava Single Background Thread Scheduler
Ich bin ziemlich neu in RxJava, also ist dies wahrscheinlich eine dumme Frage. Ich werde mein Szenario beschreiben. Ich habe Code auf dem UI-Thread, der einige Bilder aktualisiert, aber diese Bilder sind nicht sehr wichtig und verbrauchen beim ...
Rx: Ein zip-ähnlicher Operator, der fortgesetzt wird, nachdem einer der Streams beendet wurde?
Ich möchte Streams (Observables) kombinieren, die asynchron beginnen und enden: -1----1----1----1---|-> -2----2--|-> [ optional_zip(sum) ] -1----3----3----1---|->Wofür ich es brauche: Hinzufügen von Audio-Streams zusammen. Es sind Streams von ...
Android RxJava Beitrittslisten
Versuche all das RxJava-Zeug zu verstehen. Ich habe folgendes Beispiel gemacht: private Observable<List<String>> query1() { List<String> urls = new ArrayList<>(); urls.add("1"); urls.add("2"); urls.add("3"); urls.add("4"); return ...