RxJS errorでストリームが止まる

error が発生したら、後続のストリームは無視される。

obs(123)
.subscribe(cl_next, cl_error, cl_complete);
// next:123
// error:123

共通関数。

function obs(v = 0) {
  return rx.Observable.create((observer) => {
    setTimeout(() => {
      observer.next(v)
      observer.error(v)
      observer.next(v)
      observer.complete()
      observer.next(v)
    }, 1000)
  })
}
function cl_next(v) {
  console.log('next:' + v)
}
function cl_error(v) {
  console.log('error:' + v)
}
function cl_complete(v) {
  console.log('complete')
}