reactive-extensions-js

0熱

1答えて

私はこの問題をしばらく解決しようとしていましたが、これはかなり一般的な問題ですが、私がやりたいことは、観察可能な、そして増強はだから私は、次のような何かしたい、観察やpromiselike で発生： function augment(person: Person): Observable<PersonWithAddress> { // does ajax call or somethin

6熱

2答えて

RxJSの減少が継続しない

なぜフラットマップがダウンストリームの減少を引き起こさないのですか？私のようなコードを持って： handleFiles.flatMap(files => Rx.Observable.from(files). flatMap((file, i) => fileReader(file, i)). reduce((form, file, i) => { form

0熱

1答えて

特定の条件が変更されるまで、HTTPコールを一度実行して値をキャッシュする

特定のAngular2 HTTP呼び出しの結果をキャッシュする（サーバーからユーザープロファイルを取得する）と、プロファイルを更新するまでキャッシュを有効にしたい。これは私が持っているコードで、値をキャッシュしますが、プロファイルが変更されてもそれを更新することはありません。 readonly user$: Observable<User> = this.http .get(`${th

0熱

1答えて

rxjs HTTPやっ

が、私は結果の成功した通知のためのいくつかのHTTPリクエストと利用rxjsをしています要求します配列では、いくつかの値を読んで、それぞれのレポートでそれらの値を使って新しいhttpリクエストを作り直します。私は2（メンバー/レポート）+ apprを持っています。 4から8（他のもの）要求。 6〜8回のリクエストが実行されました。成功したハンドラで前の6〜8回のリクエストからすべてのデータを取得

5熱

1答えて

RxJSは約束事が非同期になるようなものです

Requesting a clear, picturesque explanation of Reactive Extensions (RX)?私はRXのことについて尋ねました。私は提供された回答のおかげで、私は今考えています。 RxJSを約束は非同期にしているようなイベントにある：私が言うhttp://reactive-extensions.github.com/RxJS/からの文章を引用し、参

0熱

2答えて

RxJS/ReactiveX適切なモジュールの通信

私はリアクティブプログラミングにはかなり新しいですが、すでに愛しています。しかし、私の脳をそれに切り替えるのはまだ難しいです。私は、「被験者の使用を避ける」、「不純な機能を避ける」、そしてもちろん「必須コードを避ける」などの推奨事項に従っています。私が達成するのが難しいのは、1つのモジュールが "アクション" /観測可能と登録し、それに反応することができる単純なクロスモジュール通信です。単純なメ

12熱

3答えて

rx.jsを使ってアレイに追加を観測できますか？

fromArray Rx wiki on github coffee> rext = require 'rx' coffee> arr = [1..5] [ 1, 2, 3, 4, 5 ] coffee> obs = rext.Observable.fromArray(arr) { _subscribe:

6熱

1答えて

Observable.IntervalのRxJS複数のサブスクリプション

RxJSには次のようなソリューションはありますか？ Is it possible to invoke subscribers's OnNexts on different threads in Rx? P.S. （CoffeeScriptの中に）私の最初の、単純なアプローチは明らかに失敗していた： hObs = Rx.Observable.interval(35000) .startWi

2熱

1答えて

なぜミドルウェアの中のObservablesを扱うのか - Observablesの組み合わせの出力をディスパッチするのか？

他のアクションを非同期的に出すアクションをディスパッチすることを奨励するこれらのミドルウェアをすべて見ると、私は狂った薬を飲んでいるように感じます。私は非同期CAN（と多分すべき？）が店の前に行われると思います。 Rxのメリットは、着信ストリームを受け取り、その一部を他のアクションの観測可能なものにマップし、結果全体をマップして一連のイベントを取得できることです。次に、各イベントをイベントにディス