Avoid creating unnecessary join points in Stream.replicate