rxjs

0熱

1答えて

startWithとshareReplayの組み合わせが不十分です。あなたがsource.startWith(0).shareReplay(1)を使用している場合は、新しいサブスクリプションは、常に0で開始し、shareReplayは無意味で、わずかに良い作品source.shareReplay(1).startWith(0)が、2つの値を受け取るために新しいサブスクリプションにつながります。

13熱

1答えて

簡単なRxJSの例題で、件名や必須の操作を使わずに状態を管理する方法は？

私は今2週間RxJSを実験していますが、原則としてそれを愛していますが、状態を管理するための正しいパターンを見つけて実装できないようです。すべての記事と質問に同意するように見えます。 Subject可能な場合は、変換を経由して状態をプッシュすることをお勧めします。 .getValue()は完全に非推奨です。 .do DOM操作を除いて、おそらく避けるべきですか？このようなすべての提案の問題は、「

1熱

2答えて

angular2：Obserable <Response> subscribeOnCompletedが

Imが、私はそのhttpリクエストにいくつかのサブスクライブを持っていると私は、すべてのサブスクライブが行われた後、機能を行うことができますしたい角度2. で要求を実行しようとしている。.. が定義されていません。 ot rxjsのドキュメントによると、subscribeOnCompletedは私が望む機能ですが、何らかの理由で私はメソッドが定義されていません。誰かがなぜアイデアを持っていますか

-1熱

2答えて

RxJS：結合ストリーム内のストリームソースを識別するための正しいパターン？

mergeまたはcombineLatest機能にどのストリームが入ってくるのかを特定する方法に関するベストプラクティスの提案を探しています。新しいストリームだけが操作されるようにします。 TODOアプリケーションのコンテキストでは、着信の追加と削除のストリームがあり、それらを結合してリストの編集を1つのストリーム内でステートレスに行うことができます。出力は、追加（連結）イベントと削除（フィルタ）イ

0熱

3答えて

件名。メッセージリスナーの例

一連のメッセージを作成する必要があります。私はシーケンスで「プッシュ」メッセージをすることができるはず私は「クエリ」のすべてのメッセージが私は新しいメッセージにすべてのリスナーに通知することができるはずすることができるはずです。は、今私はで仕上げ： var math = require('mathjs') var Rx = require('rx') var _ = require('

1熱

1答えて

RxJSの新機能では、rangeは関数ではありません

RxJSを使用するための単純なTypeScriptファイルを作成しようとしています。ここに私がやったことです：私の "index.htmlを" で、参照 "traceur & systemjs" "NPMはrxjsをインストール" およびこれに "test.ts" ファイル作成：を import {Observable} from 'rxjs/Rx'; Observable.range(1

0熱

1答えて

が観測（angular2）内のデータを操作するためのパターン何

たちは、このサービス @Injectable() export class CarService { constructor (private http: Http) {} getCars() { return this.http.get('someurl') .map(res => <Car[]> res.json())

0熱

1答えて

Rxjsでハンドルを取得しようとしていますが、このようなことをどうすればいいのですか？

rxjsのハングアップが実際に発生していますが、どこから開始するのか分かりません。これは私がしたいことです。使用fsはディレクトリを読んで、そこファイル名を指定して実行時に1つのファイルを解析し、MySQLのINSERT文を構築しますいくつかの機能のすべてのファイルを取得するにはその文を実行して成功したら、別のファイル（またはこれらのうちの約10個を同時に実行することをお勧めします）をもう一

0熱

1答えて

angular2：Obserable <Response>すべてのサブスクリプションが完了した後にresponse.json（）

私はクラスHttpを拡張しているクラスを持っています。それはMyHttpと呼ばせてください。クラスを拡張するMyJwtHttpクラスもあります。 myJwtHttp.request(..).map(res=>res.json() とrequestメソッドの実装です： class MyHttp extends Http { request(url,...){ ..

1熱

1答えて

RxJSの関数f（g（h））を機能的にどのように構成するか？アンダースコアで

そう...は http://underscorejs.org/#compose Returns the composition of a list of functions, where each function consumes the return value of the function that follows. In math terms, composing the functio