Swave - a fresh Reactive Streams Implementation
summary
A new Scala Reactive Streams toolkit claims higher performance with a shapeless-powered DSL and minimal dependencies, implementing single-use runnable graphs that run on the caller-thread execution model instead of Akka actors. It shows a Monte Carlo π demo running about a million samples/sec before optimizations, demonstrates fan-in/fan-out, coupling and a buffer-needed deadlock case (pressure must be generated), includes an ASCII graph renderer, a test kit, is open-sourced and plans a macro optimization to remove runtime overhead.
AI-written summary · about
chapters (28)
- 0:00Introduction
- 1:00Stream Processing
- 6:40Swave vs Collections
- 6:50Java Developer Example
- 7:12Initial Solution
- 7:30Scholar Collections
- 8:28Streambased solutions
- 9:10Stream transformations
- 10:08Collections
- 10:37Types of Collections
- 12:28What are Reactive Streams
- 13:11Reactive Streams vs Lazy Collections
- 15:05Simple Example
- 15:22Monte Carlo Method
- 16:33Code
- 17:22Run main
- 18:11Call of thread
- 18:58dsl basics
- 19:44Fanin
- 20:53Fanout
- 22:12Coupling
- 24:29Pipes and Modules
- 25:11Inspecting Rendering
- 25:50ASCII Rendering
- 26:14Graph Rendering
- 27:08Design Goals
- 27:39Swave vs Akka Stream
- 29:35Roadmap
related talks
50mSwave - a fresh Reactive Streams Implementation
28mStreams on top of Scala
44mScalaz Stream: Rebirth
42mLearn you Akka Streams for great Good!
56mThirst-quenching Streams for the Reactive Mind
32mThirst-Quenching Streams for the Reactive Mind
01h 01mThirst Quenching Streams for the Reactive Mind
48mStreaming all the things with Akka Streams