RxJS 学习手记

2020-04-30  本文已影响0人  Simar

参考:


在 RxJS 中用来解决异步事件管理的的基本概念是:

概念比较晦涩,通俗的说。
Observable 理解成一个自媒体。
Observer 是这个自媒体发布的作品。
Operators 是对发布作品的一系列操作,比如延迟发送作品,更新作品。
当这个事件被人订阅时(subscribe)才知道这个时间发生了。
当这个这个事件取消订阅时(unsubscribe)没有知道事件发生了。

如下例子:

  1. Up 主想发布作品123,但是Up 有一点自己小想法。
  2. 思考了1秒钟
  3. Up主想在作品123 的基础上做一些修改,并作为作品 1
  4. Up主想在作品1的基础上做一些修改,并作为作品 1Test2
  5. 最后我们看到就是Up 的作品1Test2
  rxJSTest() {
    let value =123;
    Rx.Observable.create((observe) => {
      observe.next(value);
    }).pipe(
      delay(1000),
      // pluck('error_code','Checklist','ResultTemplate',"Token"),
      concatMap((data) => {
        console.info("作品",  data);  //作品 123
        return Rx.Observable.create((observe) => {
          console.info("作品", data); //作品 123
          observe.next(1);
        });
      }),
      concatMap((data) => {
        console.info("作品 ", data); //作品  1
        return Rx.Observable.create((observe) => {
          console.info("作品 ",  data); //作品  1
          data = data+"Test2";
          observe.next(data); 
        });
      })
    )
      .subscribe((vale) => {
        console.info("作品 ",vale);//作品  1Test2
      }, err => {
        console.info(err);
      }, (vale) => { console.info("COMPLETE", vale) });
  }
}
上一篇 下一篇

猜你喜欢

热点阅读