Suchergebnisse für Anfrage "reactive-programming"
Rxjs - API-Ausgabe konsumieren und erneut abfragen, wenn der Cache leer ist
Ich versuche eine Version von @ zu implementierdieses Intro zu RxJS [https://xgrommx.github.io/rx-book/content/guidelines/introduction/index.html] ( geige hier [http://jsfiddle.net/staltz/8jFJH/48/]) Anstatt ein zufälliges Objekt aus einem ...
Warum Redux-Observable über Redux-Saga verwenden?
Ich habe benutzt Redux-Saga [https://github.com/yelouafi/redux-saga]. Code, der damit geschrieben wurde, ist bisher leicht zu begründen, außer dass mir die JS-Generatorfunktion von Zeit zu Zeit den Kopf verdirbt. Meinem Verständnis nach, ...
RxJava retryWhen bizarres Verhalten
Ich spiele mit dem RxJava retryWhen [http://reactivex.io/documentation/operators/retry.html] Operator. Im Internet wird nur sehr wenig darüber gefunden. Der einzige, der es wert ist, erwähnt zu werden, ...
Chaining Observables in RxJS
Ich lerne RxJS und Angular 2. Nehmen wir an, ich habe eine Versprechenskette mit mehreren asynchronen Funktionsaufrufen, die vom Ergebnis des vorherigen abhängen und wie folgt aussehen: var promiseChain = new Promise((resolve, reject) => { ...
Begrenzung gleichzeitiger Anforderungen mit Rx und SelectMany
Ich habe eine Liste mit URLs von Seiten, die ich gleichzeitig mit @ herunterladen möchtHttpClient. Die Liste der URLs kann groß sein (100 oder mehr!) Ich habe derzeit diesen Code: var urls = new List<string> { @"http:\\www.amazon.com", ...
Paginate Beobachtbare Ergebnisse ohne Rekursion - RxJava
Ich habe ein ziemlich standardmäßiges API-Paginierungsproblem, das Sie mit einer einfachen Rekursion lösen können. Hier ist ein Beispiel: public Observable<List<Result>> scan() { return scanPage(Optional.empty(), ImmutableList.of()); } private ...
Chaining RxJs Observables in Angular 2
Ich habe eine TypeScript-Funktion in meiner Angular 2-App, die eine Observable zurückgibt, um Web-API-Daten an den Consumer zurückzusende public getApiData(): Observable { let readySource = Observable.from('no', 'no', 'ready'); let dataSource = ...
RxJS warten, bis das Versprechen gelöst ist
Ich bin mir immer noch sicher, dass es sich um eine reaktive Programmierung handelt, daher bin ich mir ziemlich sicher, dass dies sehr einfach ist, aber die Anzahl der Stream-Transformationen ist für Anfänger ziemlich überwältigend. Ich ...
Holen Sie sich den neuesten Wert eines Observable und senden Sie ihn sofort aus
Ich versuche, den neuesten Wert eines gegebenen @ zu erhaltObservable und lasse es sofort ausgeben, sobald es aufgerufen wird. Als Beispiel sei der folgende Code angeführt: return Observable.just(myObservable.last()) .flatMap(myObservable1 -> { ...
Wie verwende ich Observable.fromCallable () mit einer aktivierten Ausnahme?
Observable.fromCallable() eignet sich hervorragend zum Konvertieren einer einzelnen Funktion in eine Observable. Aber wie gehen Sie mit überprüften Ausnahmen um, die von der Funktion ausgelöst werden könnten? Die meisten Beispiele, die ich ...