Practical Reactive Streams with Monix
summary
Processes gzipped CSV lines with Monix Observables, parses each line into a domain Reading Task, groups readings by ID in pairs, computes averages (invalid pairs yield -1), and writes results concurrently to Cassandra; the pipeline composes transformers (parseFile → average → storeReadings) and runs as an Observable consumed with forEachParallel. Implements mapAsyncOrdered using bufferTumbling + Task.gather to parallelize while preserving result order. Example runs end-to-end (few-second run), but scheduler/ExecutionContext choice affects performance and ordering tradeoffs.
AI-written summary · about
chapters (7)
- 0:00Introduction to reactive streams
- 3:53Introduction to monix
- 6:34Parsing CSV files with monix
- 12:31Processing data and computing averages
- 18:05Assembling the pipeline
- 22:56Execution and thread management
- 27:13Ordering and closing thoughts
related talks
32mPRACTICAL REACTIVE STREAMS WITH MONIX
46mTame Your Data with Akka Streams
49mA Practical Introduction to Akka Streams
01h 07mA Practical Introduction to Akka Streams
37mA Tale of Two Monix Stream
11mStreaming Libraries Shootout
51mScalaz Streams A Functional Approach to Compositional...
42mMonix Task: Lazy, Async and Awesome