RxJS を学ぼう #4 - COLD と HOT について学ぶ / ConnectableObservable | Recruit Tech Blog
RxJS を学ぼう #4 - COLD と HOT について学ぶ / ConnectableObservable wakamsha これはいわゆる『COLD』という性質に限った話であり、実は Observable には subscribe せずともデータを流す仕組みが用意されています。そのような性質を『HOT』と呼びます。この二つの性質の違いを理解することは Rx を使いこなす上で避けて通ることは出来ません。今回はこれら COLD と HOT についてご紹介します。 COLD 1) subscribe されるまで値を流さない COLD は下流で subscribe されるまで値を流しません ( ストリームが稼働していない状態 ) 。仮に subscribe されていない Observable に値を流しても流れが途切れるだけで、値は処理されることなく消滅してしまいます。通常、Observa
How do I force a refresh on an Observable service in Angular2?
In ngOnInit, my component obtains a list of users like so: this.userService.getUsers().subscribe(users => { this.users = users; }); And the implementation of userService.getUsers() looks like this: getUsers() : Observable<UserModel[]> { return this.http.get('http://localhost:3000/api/user') .map((res: Response) => <UserModel[]>res.json().result) .catch((error: any) => Observable.throw(error.json()
RxJSでMVVMやってる - @hadashiA
Rxは、すごくUIを書くのに向いているのではないだろうか。アプリケーションの状態を山盛りの変数で管理することから解放され、状態から状態へ変換する関数を書けばよくなるから。 非同期処理を同期っぽく書きたいならawait でいいじゃん。UIイベントを宣言的に書きたければ 2-wayバインディングがあれば良いじゃん。という話では終わらず、その辺の問題解決に加えて、値の発生器を全て同じ宣言にまとめられ、状態変数がなくなるところが書いていて楽しいところです。 // たとえば、、 Observable.fromEvent(searchBox, 'input') // 検索窓に字が打ちこまれたら .debounce(500) // 0.5秒ごとに .map(e => e.target.value) // 入力されたテキストを .filter(q => q.length > 0) // 1文字以上の場合だ
1
リリース、障害情報などのサービスのお知らせ
最新の人気エントリーの配信
処理を実行中です
j次のブックマーク
k前のブックマーク
lあとで読む
eコメント一覧を開く
oページを開く
How to catch error and continue executing a sequence in RxJs?
The data health blog
