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.