Direct-style concurrent streaming for Scala | Adam Warski SoftwareMill

A tour of Ox Flow: an API for defining local data transformation pipelines, which focuses on performance and simplicity. Combines operators well known from Akka Streams or FS2, with the extensibility of Kotlin Flow, and programmer-friendliness of Java 21 & Virtual Threads.

RESOURCES
Ox on GitHub: https://github.com/softwaremill/ox
Ox Flow documentation: https://ox.softwaremill.com/latest/st...
WebSocket chat example: https://github.com/softwaremill/sttp-...
ChatGPT proxy example: https://github.com/softwaremill/tapir...

CHAPTERS
00:00 Ox & Ox Flow introduction
02:01 Simple non-concurrent flows
06:52 Concurrent flows: zip
09:33 Concurrent flows: merge
11:48 Concurrent flows: mapPar & blocking operations
16:14 Loom benefits: control flow
19:29 Loom benefits: exceptions
21:24 Flow internals
23:39 Redis streams example
26:36 Adding Ox Flow integration
31:24 Kafka integration demo
35:10 Summary

#softwaremill #scala #functionalprogramming