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方法
【RxJs学习笔记7--出错处理与完结】复习一下,这个方法用作发布者构造函数的参数。
const onSubscribe = observer => { //数据流 observer.next(1); observer.next(2); //错误 observer.error('some error msg'); //完结 observer.complete(); }

    推荐阅读