Parallel stream processing