PRACTICAL REACTIVE STREAMS WITH MONIX

on YouTube ↗32m

" summary

Live coding shows a working pipeline that reads files, parses lines into a Reading ADT, groups readings in pairs (buffer size 2) to compute averages (falls back to -1 for completely invalid pairs), and writes ValidReadings concurrently into Cassandra running in Docker. Core tools are Monix Observable plus lazy Task for async work, a custom ordered map-async using buffered tumbling and merging, and a consumer with configurable parallel writes; the importer runs and completes with logged success.

AI-written summary · about

" chapters (8)

1. 0:00Intro
2. 3:28What is Monix
3. 4:45Use Case
4. 5:34Coding
5. 10:00Average
6. 21:17Execution context
7. 23:36Paralysis
8. 30:34Conclusion

" related talks

• 35mPractical Reactive Streams with MonixJacek Kunicki · Scale By The Bay 2018
• 37mA Tale of Two Monix StreamAlexandru Nedelcu · Scala Days Berlin 2018
• 46mTame Your Data with Akka StreamsJacek Kunicki · Scale By the Bay 2017
• 49mA Practical Introduction to Akka StreamsJacek Kunicki · Voxxed Days Vienna 2017
• 01h 07mA Practical Introduction to Akka StreamsJacek Kunicki · JDD 2016
• 11mStreaming Libraries ShootoutGideon Caller · Scalapeño 2018
• 32mThirst-Quenching Streams for the Reactive MindMary Grygleski · jLove 2020
• 51mScalaz Streams A Functional Approach to Compositional...Derek Chen Becker · LambdaConf 2015