rxjs5

0熱

2答えて

現時点では、私は次のことを達成しようとしています。 - テキスト入力フィールドとボタンがあります。ボタンをクリックすると、入力から値を取得します（rxjs経由）。以下は私がセットアップしたものです。現在、ボタンクリックのObservableがあり、現在、BehaviorSubjectを更新している入力テキストフィールドがあります。私が実行したり頭を悩ましているのは、値がクリックストリームに送信さ

4熱

1答えて

RxJS：複数のネストされたオブザーバをバッファと組み合わせる方法

警告：ここにRxJS newbがあります。ここでは私の課題です： onUnlink$観測可能発する... は、すぐに（私はこのパーティションonAddBuffer$と呼ぶことにします）1秒の最大のために、観測可能onAdd$から値をキャプチャを開始すると。 onAddBuffer$に観察試合doc$値からの値のいずれかが、我々は onAdd$値のいずれかにマッチするために使用しますモデルをフェッ

0熱

1答えて

HTTPコールの前に非同期的に認可トークンを取得する

これを投稿する前に私は他の多くの同様の質問に行き、解決策を見つけることができませんでした。 like Angular 2 - Inject authorization token before each Http request 私はHTTPリクエストを作成するための承認トークンを提供するAWSセッションを使用しています。今セッションを取得することは、トークンをリフレッシュする必要性に応じて、非同

2熱

1答えて

同期オブザーバブルを列挙する方法は？

たとえば、観測可能なfrom(['a', 'b'])がある場合、[0, 'a']と[1, 'b']を放出する観測値を取得する方法はありますか？私はfrom('a', 'b').pipe(zip(range(0, Number.POSITIVE_INFINITY)))を試してみましたが、これは無限ループを作成します：あなたは、コンソールでRx.Observable.from(['a', 'b'])

1熱

1答えて

rxjs5 - WebSocketSubjectはコンストラクタではありません

したがって、rxjsのObservable.webSocketをnode.js環境で使用しようとしています。私はドキュメントとthisスタックオーバーフローポストから、自分自身のバージョンのwebsocketを提供する必要があることを知りました。私が遭遇する問題は、提供された両方の例がWebSocketSubjectを示しているが、どこから来るのかは言及していない。 const ws = requ

-2熱

1答えて

Observable内の複数のオブザーバブルが期待どおりに解決されていない

私はそれを見ると簡単な質問がありますが、Rxで十分な経験がありません。 ngOnInit() { this.agentService.getAllAgents().subscribe((agents: Agent[]) => { this.agents = agents.sort((x: Agent, y: Agent) => Number(new Date(x.date))

0熱

1答えて

RxJS ajaxがヌル応答を返す

rxjsを使用していくつかのデータを取得しようとしています。 200を返しますが、応答はnullです。レスポンスを取得するための余分なステップはありますか？テストapi; https://reqres.in ありがとうございました。 import {ajax} from 'rxjs/observable/dom/ajax'; import 'rxjs/add/operator/map';

0熱

1答えて

rxjs publishReplay：リセット時にリセット

私は、httpリクエストをAngular5でキャッシュするために、publishReplay（1）.refCount（）を使用しています。これは正常に動作します - エラーの場合を除きます。私は飲み込んで、http-sourceから例外を報告しています。そのため、以下のコードでObservable.of（undefined）を渡しています。その場合、キャッシュは未定義ですが、サブスクライバはその

6熱

1答えて

RxJSのlettable演算子として `do`を使うにはどうすればいいですか？

RxJS 5.5は、賃貸可能演算子をつかみ、そうのようにそれらをパイプことができます： import { ajax } from 'rxjs/observable/dom/ajax' import { catchError, map, retry } from 'rxjs/operators' ajax.getJSON('https://example.com/api/test') .pi