RxJS 6 —— Subscription

Subscription

Subscription was called “Disposable”.

unsubscribe : release resources or cancel Observable executions

• ob.subscribe

  的返回类型是

  subscription

import  { interval, Observable, of } from 'rxjs';

const observable = interval(200);
const subscription = observable.subscribe(x=>console.log(x));
// subscription.unsubscribe();
setTimeout(() => {
    subscription.unsubscribe();
}, 1100);
           

管理多个subscription

• add()

import  { interval, Observable, of } from 'rxjs';

const observable = interval(200);
const ob2 = interval(200);
const subscription = observable.subscribe(x=>console.log(x));
const sub2 = observable.subscribe(x=>console.log(x*2));
// subscription.unsubscribe();
subscription.add(sub2);
setTimeout(() => {
    subscription.unsubscribe();
}, 1100);

           

• remove()

import  { interval, Observable, of } from 'rxjs';

const observable = interval(200);
const ob2 = interval(200);
const subscription = observable.subscribe(x=>console.log(x));
const sub2 = observable.subscribe(x=>console.log(x*2));
// subscription.unsubscribe();
subscription.add(sub2);
subscription.remove(sub2);
setTimeout(() => {
    subscription.unsubscribe();
}, 1100);