rxjs5

0熱

2答えて

RxJS：サブスクリプションの瞬間にのみ放出されるObservableデータをどのように購読しますか？

コンテキスト：私は多くのConnectableObservableを持っています。ほとんどすべて再生回数が1以上です。ある時点で、オブザーバブルの購読と購読解除のオブザーバが多数存在します。私が望むもの：多くの場合、オブザーバーがこれらのオブザーバブルの1つにサブスクライブすると、観測可能なデータ再生メカニズムのために受信した可能性のある既存の放出データが気になりません。最近購読されたオブザーバ

7熱

1答えて

RxJS 5からの退会はどのようにしてできますか？

私はこのパターンを使用している： func myObservable() Observable<boolean> { ... } func myFunc() { myObservable().subscribe((cond: boolean) => { if (cond) { // How do I unsubscribe here?

3熱

1答えて

RxJS 5 Observable：既知のセットに属する結果がありますか

Typescript 1.9にコーディングし、RxJS 5を使用しています。私はの放射のいずれかが固定された数の配列に属している場合、ただ1つの値、すなわちtrueを放出する観測可能物を構築しようとしています。それ以外の場合はfalseです。これは私のコードです： let lookFor = [2,7]; // Values to look for are known Observable.fr

0熱

1答えて

ドロップダウンの値からデータをフィルタリングする

選択ボックスの選択値に基づいてデータをフィルタリングしたいと思います。私が持っているデータ <select id="testDD"> <option value="local">Local</option> <option value="international">Internationl</option> </select> <div id="list"><!-- Li

0熱

3答えて

RxJS明確化が必要：Observableではなく普通のオブジェクトを返す方法

私は角度2のバリデーター関数を書いています。の代わりにの代わりにという平文のオブジェクトを返したいと思います。ここでは私の現在の実装である： import {AbstractControl} from "@angular/common"; import {UserAccountService} from "../../useraccount/useraccount.service"; e

0熱

1答えて

typescriptですに従うように私はrxjsを使用して

すべてのJavaScriptファイルをロードするためには避けてください： import {Observable} from "./rx/Rx" var main =() => { $(".ui.dropdown").dropdown(); $(".left-half").backstretch(["../images/lotus.jpg"]); var sou

0熱

1答えて

RxJS Observable＆Observerの問題

アプリユーザーを認証してログインするために、いくつかの手順を実行するAngular 2サービスがあります。 Observerでnext（）を呼び出そうとするたびに、私は定義されていないというエラーが出ます。 Observableがインスタンス化されたときに、私がnext（）を呼び出すことができる唯一の場所はコンストラクタの内側です。 authenticateUser（）を呼び出すと、this.is

0熱

2答えて

.scan（）は未完成の配列でもっとも最近発行された配列のみを集める

観測可能な配列の要素を変換して集約する必要があります。シーケンスは開いており、完了することは決してありません（ネットワークベース）。私は現在、次のコードを使用しています： const numbers = [1,2,3]; const numbers$ = new Rx.Subject(); const output = numbers$ .flatMap(n => n)

2熱

3答えて

オブザーバブルと並行してファイルを読む

私は、選択したファイルをユーザが読み込んでbase64に変換するアプリケーションを作成しています。私は、すべてのファイルがメモリに読み込まれたときに通知を出したい。この目的のために私はのイベントをFileReaderとして扱い、完全な通知を送るObservableを使用しています。私はforkJoinを使って操作を並行して実行しています。 Observableを作成して購読しているコードを下に見て

3熱

1答えて

多くのRxJS観測可能演算子を連鎖させる問題

私は、観測値を連鎖させるために最もクリーンな解と演算子を見つけようとしています。次のように私の要件は次のとおりです。は、バックエンドにHTTP呼び出しを行うためにuserAcccountTokenは再び別のものを行うためにuserAcccountTokenを使用することを利用のparamsルートからを取得しますバックエンドへのhttpコール最後にすべてがうまくいけば、ルート（つまり/