Re: [akka-user] Newbie question about storing ActorRef in a member variable

One correction: Future.value is not blocking, it returns the current state of the Future. Which means there is a good chance the Future will not be complete and None will be returned even if the actor exists. On Tue, 7 Jun 2016, 20:12 Justin du coeur, wrote: > Actually,

Re: [akka-user] What are the correlation between ByteString in Akka Streams TCP packet payloads?

If it helps, a simple custom framing stage could look like this: Flow[ByteString].statefulMapConcat[MyThing] { () => var buffer = ByteString.empty in => { val (things, remaining) = parseThings(buffer ++ in) buffer = remaining things } } def parseThings(bytes: ByteString):

Re: [akka-user] Futures, Ask, and receive invocations. How are they handled in Akka?

The sender for the message will be linked back to the specific Future. As long as the original sender is used to reply, the expected Future will be completed. On Thu, Mar 24, 2016 at 7:28 PM Mohammed Al-Mahfoudh < mohammed.mahfo...@gmail.com> wrote: > Hi there, > > > We are developing a tool to