Top "Akka-stream" questions

Akka implementation for handling streaming data on the JVM

Proper way to stop Akka Streams on condition

I have been successfully using FileIO to stream the contents of a file, compute some transformations for each line and …

Read More
scala akka-stream
Accessing the underlying ActorRef of an akka stream Source created by Source.actorRef

I'm trying to use the Source.actorRef method to create an akka.stream.scaladsl.Source object. Something of the form …

Read More
scala akka akka-stream
How to download a HTTP resource to a file with Akka Streams and HTTP?

Over the past few days I have been trying to figure out the best way to download a HTTP resource …

Read More
scala akka-stream akka-http
Why is Akka Streams swallowing my exceptions?

Why is the exception in import akka.actor.ActorSystem import akka.stream.ActorMaterializer import akka.stream.scaladsl.Source object TestExceptionHandling { …

Read More
scala exception-handling akka-stream
Akka Streams: State in a flow

I want to read multiple big files using Akka Streams to process each line. Imagine that each key consists of …

Read More
scala stream akka akka-stream stateful