Pipelet.._add_source(): replace by new closure when source becomes a union