talk · community record
Scraping Reddit with Akka Streams
"Reactive Streams is an initiative to provide a standard for asynchronous stream processing with non-blocking back pressure on the JVM." - reactive-streams.org Akka streams is Typesafe's implementation of the Reactive Streams standard. It provides a high level DSL for building composable stream processing pipelines. This talk will introduce Akka Stream concepts like sources, flows, sinks, and flow graphs by building a throttled stream processing pipeline for scraping Reddit comments and persisting the resulting word counts. Plenty of in-REPL examples. Based on this tutorial: https://github.com/pkinsky/akka-streams-example