RxJs学习笔记7--出错处理与完结

当发布者完成数据发布任务，或者数据流出现错误时，会通知订阅者出错或者完结信息。通知方式就是调用订阅者的error方法或者complete方法。因此，需要出错处理或者结束机制时，订阅者需要实现error方法或者complete方法，去完成处理。

订阅者对象

const theObserver = {
  next:item => console.log(item),
  error: err => console.log(err),
  //complete方法不需要接收数据（或称之为参数）
  complete: () => console.log('No More Data')
}

onSubscribe方法

复习一下，这个方法用作发布者构造函数的参数。

const onSubscribe = observer => {
  //数据流
  observer.next(1);
  observer.next(2);
  //错误
  observer.error('some error msg');
  //完结
  observer.complete();
}