feat(streaming): propagate stream-completeness errors to consumer