Pipelet.add_source(), fetch() receiver: throw exception when [] received twice