Source actorRef[T] behaviour with Success objects

Akka Akka Streams & Alpakka
1

Hey there,

I’m using a Source.actorRef[T] and sending it an akka.actor.Status.Success when stream processing is to complete. What I’m finding though is that the Success object is carried through the Source.actorRef's stream… which of course isn’t of type T and therefore renders as a class cast exception.

Thoughts?

Cheers,
-C

2

You are supposed to send the instance of the Success class instead of the Success object itself.

1 Like
3

Oh!

Subsequent browsing shows that I’m not the only person that had such difficulty. I’ll try and get to a PR for the following issue next week:

4

Thanks for the help!

5

Just to close this off, I’ve now raised a PR.

2 Likes