美文网首页
RxJS源码解读之Observer

RxJS源码解读之Observer

作者: 随笔记记 | 来源:发表于2018-12-02 18:46 被阅读0次

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*/ }

};

相关文章

网友评论

      本文标题:RxJS源码解读之Observer

      本文链接:https://www.haomeiwen.com/subject/qnqscqtx.html