partitionedstream handling using partitionStreamEvent