処理の完了を捉える

このレッスンでは Observable から 送るデータの流れを メソッドで完了させます。 今開いてる HTML のドキュメントに 書いてある RXJS のコードなんですが これは Observable create で observable の オブジェクトを作っています。 中に定めるデータの送り方ですね。 next で数字１、２、３を送っています。 その後 setTimeout で少し時間をおいて 非同期ですね、次に４を送ってるんですね。 １秒後に送られます。 さてこの observable の オブジェクトに対して subscribe しないと 実行されません。 subscribe の引数には next でデータが 流れてきたらどう処理するのかという事で 流れてきたデータを console.log で value コロン、１、２、３と。 それからしばらく経って４という風に 出てくるようになっています。 ではここで５も加えましょう。 コピーして ペーストして５と。 ４、５が１秒後に 現れるわけですね。 保存して確認してみます。 ブラウザウィンドウに console を 出してありますのでリロードします。 そうすると１、２、３、end しばらくしてから４、５と出てきましたね。 最初に start があるんですが、start で まずこれは同期的に送る部分ですね。 １、２、３を同期的に送って そして end という風になっていて 非同期で１秒後で４、５と 出てるわけですけれども もう一回確認しときましょうか。 start 1、2、3、end、4、5 という風に 出てきました。 さてデータを流すのはもうやめよう という場合には complete というメソッドを observer に対して呼び出します。 ではこの４と５の間に ここでおしまいという事で observerに対して complete と。 complete は引数はありません。 実行してみます。 そうするとここでおしまいと 言われたのでこの next、５ですね これは実行されない事になります。 ということで保存して確かめましょう。 ファイルを保存します。 ブラウザウィンドウをリロードすると 1、2、3、end ４が出てきて５は もう出てこなくなりましたね。 complete でデータを送るのが…