Scalaz Streams A Functional Approach to Compositional...

on YouTube ↗51m

" summary

Library claims type safety, scalaz-stream composition and resource safety and shows concrete tradeoffs: some features are trimmed for performance, some concurrency bugs in 0.7.x get fixed. Examples use the Task monad, io.resource and toInputStream, plus queues, topics, signals, merge and bounded parallelism. Production uses include AMQP and Kafka adapters at Simple Energy processing terabytes without blowing the heap. A real pipeline example counts successes vs failures (3 successes and 1 parse failure) and the accumulator-based collector runs and reports correctly.

AI-written summary · about

" chapters (11)

1. 0:00Start
2. 2:47Performance
3. 4:14What Is a Process
4. 6:24Repetition
5. 19:01Transform a Channel
6. 21:30Concurrency within Processes
7. 23:36Air Handling Patterns
8. 24:04Disjunctions
9. 30:15Real World Usage
10. 38:01Checkpointing
11. 38:20Stream Async

" related talks

• 44mScalaz Stream: RebirthJohn A De Goes, Itamar Ravid · Scale By The Bay 2018
• 29mAn Introduction to Scalaz-StreamPaul Chiusano · Northeast Scala Symposium 2014
• 28mStreams on top of ScalaQuentin Adam · Scalar Conference 2015
• 01h 05mLawful Asynchronous ProgrammingDaniel Spiewak · Scala World 2015
• 01h 07mA Practical Introduction to Akka StreamsJacek Kunicki · JDD 2016
• 48mStreaming all the things with Akka StreamsJohan Andrén · Voxxed Days Zurich 2017
• 46mTame Your Data with Akka StreamsJacek Kunicki · Scale By the Bay 2017
• 35mPractical Reactive Streams with MonixJacek Kunicki · Scale By The Bay 2018