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

015 at 10:37:43 AM UTC-4, Brandon Gauthier wrote: > > When I change the code to the following I still get the same exception, > Success cannot be cast to Message. > > val (actorRef, futureThreadedResult) = Source.actorRef[Message](1000, > OverflowStrategy.fail) > //XXX debu

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

trategy.fail).toMat(Sink.publisher)(Keep.both).run() > val sourceActor = Source(publisherActor) > > /Patrik > > > On Mon, Jun 29, 2015 at 10:53 PM, Brandon Gauthier > wrote: > >> Hello, >> >> I'm using Source.actorRef[...] for a unknown size but bounde

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

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 . Client1->Act