rxjs5

1熱

1答えて

私は、各オブジェクトを別々に非同期メソッドに渡す必要のあるオブジェクトの配列を持っています（プロキシで処理された後、Observable.fromPromise(...)経由でObservableに変換されます）単一のオブジェクトがいつでも渡され、プロセスがオブジェクトをデータベースに保存している場合に、同じメソッドが使用されるため、方法が必要です）。例えば、これはオブジェクトの配列である： [

1熱

1答えて

observable forkjoinはobservableを実行しませんangular2

forkJoinを使用して、それぞれが観測可能（getImage関数内）にラップされた複数のXHR要求（内部でgetImages関数）を実行しようとしています。しかし、要求のどれも実行されない、すなわちobserver.next()は決して実行されない。私はforkJoinの代わりにzipを使ってみましたが、どちらもうまくいきません。私が作成しているすべてのオブザーバブルにcompleteができる

0熱

1答えて

Observable.ifを使用すると、1つのブランチの機能が常に実行されます。

Observable.ifを使用して、どのアクションをディスパッチするかを決定しています。 trueであるため、以下のコードはACTION1です。正しいです。しかし、私はmyFunction()は私が期待していなかったにも動作していることがわかりました。任意の説明は素晴らしいものです。おかげ myFunction() { console.log('I did not expect t

3熱

1答えて

RxJs WebSocketSubjectに接続した場合のイベントの取得

WebSocketSubjectが接続されている場合、どのように応答することができますか？ソースコードで（https://github.com/ReactiveX/rxjs/blob/master/src/observable/dom/WebSocketSubject.ts）彼らはタイプのopenObserverメンバーNextObserver<Event> socket.onopen = (e

1熱

1答えて

rxjs/Subject（Observable.from対Observable.of）からの配列の復帰

私はバックエンドWebApiと通信するためにWebSocketを使用しています。私のサービスから私のカスタムオブジェクトを返すことはできませんが、すべてがうまくいきます。私は角度4.3.4とrxjs 5.4.3を使用しています。 //ngInit from my component ngOnInit() { this.modelsSubscription = this.mainSer

-1熱

4答えて

サービスによって返された観察可能で

を完了しません私はの角度HTTPサービス @Injectable() export class MyService { constructor(private http: Http) { } getThings() { return this.http.get('url').map((res) => { // massage data here an

1熱

2答えて

RXJSで約束のリストを連鎖する方法は？

RXJSで約束のリストをどのようにチェーン化できますか？すべての約束は、前の問題が解決されたときに実行される必要があります（仕事はステートフルです）。私はこのような何かを考えていた const workTodo = []; // an array of work const allWork = Observable.create(observer => { const next=()

-1熱

1答えて

Rxjsページ内のデータを返すサービスを呼び出す

リスト["A"、 "B"、 "C"]内の項目ごとにWebサービスを呼び出す必要があります。サービスはページ単位でデータを返します（デフォルトページサイズ100）。サービスの最初の呼び出し（パラメータとしてpage = 1）は、応答としてヘッダーとして設定されたレコードの総数を持ち、それに基づいてサービスを複数回呼び出す必要があります。そして私は、すべての呼び出しの応答を待って、さらなる論理を進める

0熱

1答えて

私の観測対象の後続サブスクリプションを正しく呼び出す/管理するにはどうすればよいですか？

私はすべての加入者にプッシュする観測可能にしようとしましたが、複数のサブスクリプションで問題が発生しました。加入者管理が私のために自動的に処理されたことは私の理解であった。次の例では、 'a'と 'b'の両方を記録することが私の目標です。 let observer = null as any; let ob$ = new Observable<any>(ob => { //this p

0熱

1答えて

RxJSで使用されるデフォルトスケジューラを変更するにはどうしたらいいですか？

もっと古い私が知っている限り、RxJS 4私はDefaultScheduler.prototypeのパッチを適用してデフォルトスケジューラを変更することができました。それは正しいのでしょうか、それとももっと良い方法がありますか？これは新しいRxJS 5を実現することができますか？ソースで見たように、彼らはnullを猿のパッチを当てることができないデフォルトスケジューラーとして使用しているからです