RxJS Observableの流れ

Observableの作成流れ

①Observableを作る(rxjs)
　➡︎const {Observable} = rxjs;

②Observableの処理を作成する(Observable.create)
   const aaa = Observable.create((observer) => {
　　observer.next(1);
   console.log('sample');
   observer.complete();
   observer.error('error');
}

③Observableの処理を実行する(subscribe)

 aaa.pipe().subscribe((x) => console.log(・・・));
 aaa.pipe().subscribe((c) => console.log(・・・));

④Observable処理の取り消し(unsubscribe)
　→subscribe実行で、はじめて処理が実行され、unsubscribeで処理実行が取り消されます。

　　　　　//①を省略、②
　        const test = Observable.create((observer) => {
            observer.next(1),
            observer.next(2),
            observer.next(3),
            setTimeout(()=>{
                observer.next(4)
            },1000);
        })
　　　　　//③
        const subscription = 
        test.pipe().subscribe(
            (x) => console.log(`${x} :`,x ** 2)
        );
　　　　　//④
        subscription.unsubscribe();