high-throughput stream processing