How can I handle errors in Akka Streams?

How can I handle errors in Akka Streams?

In Akka Streams, you can handle errors using the recover and recoverWith methods. These allow you to define fallback strategies for handling failures.

Can you give me an example of using recover?

Sure! Here's a simple example: you can use recover to provide a default value when an error occurs in a stream. For instance:

val source = Source(1 to 10)
  .map(x => if (x == 5) throw new RuntimeException("Error!") else x)
  .recover { case _: RuntimeException => 0 }

source.runForeach(println)

What about recoverWith? How is it different?

recoverWith allows you to return a new stream in case of an error, rather than just a default value. This is useful for more complex error handling.

Can you show me a recoverWith example?

Absolutely! Here's an example:

val source = Source(1 to 10)
  .map(x => if (x == 5) throw new RuntimeException("Error!") else x)
  .recoverWith { case _: RuntimeException => Source.single(0) }

source.runForeach(println)