A Tale of Two Monix Stream

on YouTube ↗37m

" summary

Monix v3 adds Cats integration and a new pull-based stream called Iterant, and contrasts two concrete implementations: push-based Observable with Ack backpressure that uses Tasks/Futures and complex, high-performance flatMap state machines, and pull-based Iterant with batched iterators that favors referential transparency, resource-safe short-circuiting and interpretable code. Benchmarks show Observable often yields higher throughput while batched Iterant narrows the gap; both speak Reactive Streams for interop. Implementation complexity and memory-safety trade-offs determine which to choose.

AI-written summary · about

" chapters (18)

1. 0:00Intro
2. 0:28About Monix
3. 3:11Observable
4. 5:40Problems
5. 6:49Protocols
6. 10:57Observability
7. 15:07Poolbase
8. 16:21State Machines
9. 19:45Scala
10. 24:45Iterator
11. 25:20Iterator vs observable
12. 27:08Flatmap
13. 27:57Benchmarks
14. 28:27Runt
15. 29:17ThirdRight
16. 31:56Conclusion
17. 32:37Reactive Streams
18. 33:05Implementation

" related talks

• 32mPRACTICAL REACTIVE STREAMS WITH MONIXJacek Kunicki · Scalar 2018
• 35mPractical Reactive Streams with MonixJacek Kunicki · Scale By The Bay 2018
• 56mThirst-quenching Streams for the Reactive MindMary Grygleski · Developer Summit 2020
• 49mThirst Quenching Streams for the Reactive MindMary Grygleski · Devnexus 2020
• 55mDemystify the Reactive JargonsMushtaq Ahmed · Functional Conf 2014
• 01h 01mThirst Quenching Streams for the Reactive MindMary Grygleski · Global Summit for Java Devs 2020
• 37mAkka & Monix: Controlling Power PlantsAlexandru Nedelcu · Typelevel Summit Oslo 2016
• 27mReactive Programming in NodeEstefania Morton · NodeConf NL 2019