当发布者完成数据发布任务,或者数据流出现错误时,会通知订阅者出错或者完结信息。通知方式就是调用订阅者的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();
}
网友评论