RxJS源码解读之Observer

Observer

Observer是一个对象,用来做subscribe方法的参数,这个对象含有一个closed属性,以及next,error,complete三个方法

用法


const observer = {

  next: x => console.log('got value ' + x),

  error: err => console.error('something wrong occurred: ' + err),

  complete: () => console.log('done'),

};

observable.subscribe(observer);

源码


export const empty: Observer<any> = {

  closed: true,

  next(value: any): void { /* noop */},

  error(err: any): void {

    if (config.useDeprecatedSynchronousErrorHandling) {

      throw err;

    } else {

      hostReportError(err);

    }

  },

  complete(): void { /*noop*/ }

};

©著作权归作者所有,转载或内容合作请联系作者
平台声明:文章内容(如有图片或视频亦包括在内)由作者上传并发布,文章内容仅代表作者本人观点,简书系信息发布平台,仅提供信息存储服务。

推荐阅读更多精彩内容

  • 文章作者:Tyan博客:noahsnail.com | CSDN | 简书 深度学习用python跑数据时,经常会...
    SnailTyan阅读 5,785评论 0 0
  • 姓名:戴学亮 公司:海南蔚蓝时代实业有限公司 组别:第420期利他3组 【日精进打卡第23天】 【知~学习】 《六...
    邻家阿太阅读 942评论 0 0