why is the error re-emitted? Also shouldn't the once() be applied on any error coming from the pipeline, not individually emitted errors?