`Sink.actorRef` with `sender`

Akka Akka Streams & Alpakka
1

Say I have an actor that does this:

  override def receive: Receive = {
      case _ => Source(List(1, 2, 3)).runWith(Sink.actorRef(recipient, Status.Success))

The sender of 1, 2, 3 will be deadLetters. How can I make parent actor that runs the graph the sender of the messages of Sink.actorRef?

1 Like
2

Found the solution:

Instead of

Source(List(1, 2, 3)).runWith(Sink.actorRef(recipient, Status.Success))

do:

Source(List(1, 2, 3))
    .concat(Source.single(Status.Success))
    .recover({ case e => Status.Failure(e) })
    .runForeach(recipient ! _)

I’m keeping monologue here, asking questions and then answering them myself…

1 Like