Highest-performance Stream Processing
summary
Library implements complete stream fusion and generates C and OCaml code from declarative pipelines, eliminating intermediate tuples and allocations so pipelines run in constant memory and without function-call overhead. It supports map, filter, take/drop, zip, flatmap, tupling and stateful streams for windowing and compression, emits vectorized AVX loops, produces ~260 lines of C for a DSP pipeline, sustains ~10 million 32-bit samples/sec for an FM receiver, and matches handwritten imperative baselines while handling zip+flatmap cases that make others slow.
AI-written summary · about