Scalaz Stream: Rebirth
summary
A next-generation scalaz-stream reimplementation targets the Scalaz 8 / ZIO effect model, exposing only Stream and Sink and abandoning spine deconstruction and cyclical graphs to gain leak-free resource handling and automatic interruption. Implementation uses a left-fold/final encoding with continuations to suspend and transfer iteration, plus a toQueue primitive for composition. Benchmarks: 50M-int sum shows ~20× Akka speed, CSV tokenization is ~3× faster than FS2 (and 30× Akka in one test). Source, tests, docs and benchmarks are on a live pull request; queues and some fusion need further optimization.
AI-written summary · about
chapters (9)
- 0:00Introduction
- 1:24Modernizing ScalaZ Stream
- 3:34Motivation and API sneak peek
- 10:43Core abstractions: Stream and Sink
- 20:18Performance benchmarks
- 24:15Stream design: Folds vs initial encoding
- 31:52Overcoming fold limitations
- 37:28Future roadmap
- 40:16Q&A
related talks
51mScalaz Streams A Functional Approach to Compositional...
28mStreams on top of Scala
29mAn Introduction to Scalaz-Stream
43mThe Design of the Scalaz 8 Effect System
42mLearn you Akka Streams for great Good!
49mA Practical Introduction to Akka Streams
48mStreaming all the things with Akka Streams
01h 07mA Practical Introduction to Akka Streams
