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/streaming/flows.html * WebSocket chat example: https://github.com/softwaremill/sttp-openai/blob/master/examples/src/main/scala/examples/ChatProxy.scala * ChatGPT proxy example: https://github.com/softwaremill/tapir/blob/master/examples/src/main/scala/sttp/tapir/examples/websocket/WebSocketChatNettySyncServer.scala 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