Re: [akka-user] [akka-streams-1.0-RC4 scala] Questions about completing a stream when using Source.actorRef[...]

2015-06-30 Thread Brandon Gauthier
I've figured this out. When I send in the Status.Success messages I need to make sure it is an instance of the case class not the type, simply put: // Will work actorRef ! Status.Success(something) // Will not work actorRef ! Status.Success --Brandon On Tuesday, June 30, 2015 at 10:37:43 AM

[akka-user] [akka-streams-1.0-RC4 scala] Questions about completing a stream when using Source.actorRef[...]

2015-06-29 Thread Brandon Gauthier
Hello, I'm using Source.actorRef[...] for a unknown size but bounded stream (I don't know how many elements but I do know it will end). The high level outline of the stream is below and sample code can be found in this gist https://gist.github.com/gauthierbl/9cf40135619f4c99c102.