Pipelet / Set / Aggregates: implement no_more flag for fetch() methods receivers to simplify fetch code and prevent most double end bugs