Fixed: foreachStream/partitionBy projections not-producing any results fail
with NotImplementedException