partitioned stream handling