Cleanup orderedMergeStream