Conveyor<F, O> onComplete(Conveyor<F, O> p()) => onHalt((err) => err == End ? p().asFinalizer() : p().asFinalizer().plus(halt(err)));