疑問に思っている点は、例えば
var clickStream = Rx.Observable.fromEvent(document, "mouseup"); clickStream .buffer(clickStream.throttle(250)) .map(function(x) {return x.length}) .filter(function(n) {return n >= 2}) .subscribe(function(n) {console.log(n + "click")});
のような処理があったときにどこから、処理が離れるのですか。
subscribe()
でObservable
にストリームを登録した瞬間からですか?
また、どこら辺からメインスレッド?がストリームの処理を始めるのですか。
ストリームにイベントがやってきたときですか?
はたまた、メインスレッドではなく、ストリーム登録後は、他スレッドがsubscribe()
に登録された関数までも処理してくれるのでしょうか?
RxJSについて、詳しい方のお知恵を御貸し頂きたいです。
お待ちしております。
あなたの回答
tips
プレビュー