observable

0熱

1答えて

Asynctask status && RxJava2で同等のキャンセルが可能ですか？

私はRxJava2を学び、AsyncTasksをObservablesに変換しようとしています。変換しようとしている次のコードがあります。 if(asyncTask.getStatus() == AsyncTask.Status.RUNNING){ asyncTask.cancel(); } asyncTask = new CustomTask(); asyncTask.exec

2熱

1答えて

RxJS観測可能なコンカットが動作しない

concatコールの処理は何ですか？私がconcatをmergeに置き換えた場合、コードは正しく動作し、出力はfoobarquxquuxです。ホットとコールドの観測値については読んだことがあります。値がサブスクリプションの前に生成された場合に発生する可能性のあるホットな観測値については、私の観測値はcoldであることがわかります。 const Rx = require('rxjs'); con

0熱

1答えて

リアルタイムでリフレッシュデータを使用した角度2のアプリケーション

私はangular4を使用しています。私はリアルタイムでobservableを使って更新しようとしています。はここで私は私がデータやフィルタを組み合わせて、これらの値はaddNeighbours配列にプッシュされlist.thenユーザーを取得した後、私はフラットのリストを取得observable import { Observable } from 'rxjs/Rx'; impor

0熱

1答えて

データを取得するためにobservableを購読する

私の観測対象に関する知識は限られているので、私がここで間違っていることは明らかです。「角度2のコンポーネント」では、この呼び出しが発生します。ユーザオブジェクトが <div class="row padding-left"> <div class="col-sm-6 base-info-container info-box-details"> <table class="i

0熱

2答えて

startWith（）はSubjectを返します

Subjectをデフォルト値で使用して値を出力したいとします。 startWith("def")がこの方法です。 subject = new Rx.Subject().startWith("def value"); 残念ながらstartWIth戻りObservableので、私は私が最初の場所で件名を使用しています唯一の理由である、onNext()を使用することはできません。この問題の回避策は何

1熱

1答えて

Angular forEachループオブザーバブルから返されたデータ（Firebase駆動）

私は観測オブジェクトを登録すると、支払オブジェクトの配列を返すサービスからオブザーバブルを持っています。ループを実行して各オブジェクトの金額を配列。最初のロードでループが実行されていないという問題は、データがまだ到着していないためです。ただし、オブザーバブルの件名を.nextトリガすれば問題ありません。そうように私のコンポーネントの機能は次のとおりです。 paymentsSource = new

0熱

1答えて

観測可能なデータと更新データを持つAPIの変更を確認してください

私は、現在ラジオで再生中の（最後の）曲に関する情報を提供するWebサービスを持っています。私の観測データは、自分自身のhttpリクエストからのデータをどのように更新できますか？マイプロバイダ： load() : Observable<{}> { return this.http.get(this.URL).map(res => res.json()); } マイコンポー

1熱

1答えて

Observableまたはlodash内の文字列としてkeyを使用して配列からオブジェクトを返す方法は？

与えられたサンプルでは、私はどのように個々のオブジェクト（ショー）を得るでしょうか？ RXJS Observableへのリターンをマッピングしていますので、RXJSまたはlodashのものを使用すると非常に便利です。 //JSON RETURNED within Observable { "shows": [ { "id": "1-abc",

0熱

2答えて

foreachループとObservableで複数の呼び出しをチェーン

私は配列から取得するURLに複数の要求をチェーンしたいと思います。次のチェーンの前に、前のものが終了するのを待っています。前回の失敗かどうかは問題ではありません。私はforkJoinでこれを試していましたが、リクエストの1つが失敗した場合はエラーを返します。 this.dataServers.forEach(dataServer => { observableBatch.push(thi