CUSTOM STREAM OPERATORS MADE SAFE AND SIMPLE WITH LIBRETTO
summary
Libretto is a Scala DSL that builds custom stream operators as declarative, provably connected diagrams rather than imperative fibers, queues and promises; examples include a dog-present assembler that conditionally pulls 3 or 5 biscuits, a competing-consumer sunflower producer that races for 3 vs 5 items, and a Digital Library of Alexandria operator that starts up to K concurrent fetches and preserves order while maximizing throughput. Operators produce well-wired diagrams, raise assembly-time errors if ports are misconnected, and integrate with ZIO Streams and prefetching of K connections.
AI-written summary · about
chapters (7)
- 0:00Introduction
- 3:59Libretto simplifies stream ops
- 14:05Packaging example with Libretto
- 14:49Competing consumers with sunflowers
- 19:06Digital Library of Alexandria case study
- 25:35Conclusion
- 26:42Q&A
related talks
01h 05mLawful Asynchronous Programming
29mAn Introduction to Scalaz-Stream
51mScalaz Streams A Functional Approach to Compositional...
28mStreams on top of Scala
42mWhen your DSL Needs to Support User-Defined Functions
44mScalaz Stream: Rebirth
30mLEARN YOU AKKA STREAMS FOR GREAT GOOD!
38mSketching streams with aquascape