Re: [akka-user] Implementation of Persistent Actor with initial state

I'm not sure I understand. You want to read the old data if the persistent actor doesn't have any events of its own? You can check the state when you get RecoveryCompleted. You can also count the events/snapshot in receiveRecover and act on that when RecoveryCompleted. /Patrik fre 14 okt. 2016

Re: [akka-user] Implementation of Persistent Actor with initial state

I think fsm has something similar to recovery completed lör 15 okt. 2016 kl. 11:34 skrev Jakub Liska : > Yes, that's what I meant. > > Perfect, it would work in Persistent Actor... What about PersistentFSM ? > I guess that I will have to introduce an initial FSMState where

Re: [akka-user] Implementation of Persistent Actor with initial state

Yes, that's what I meant. Perfect, it would work in Persistent Actor... What about PersistentFSM ? I guess that I will have to introduce an initial FSMState where I would check whether the persistent state is empty or it was recovered and act on that. Cool, thanks a lot Patrik ! On

[akka-user] Re: Simple beginner questions: Accessing values in flows

Actually, I worked it out. Thanks! On Saturday, October 15, 2016 at 12:51:10 PM UTC-4, mniel...@gmail.com wrote: > > I have the following code: > > > val cmdSrc: Source[Message, ActorRef] = Source.actorRef[Message](10, > OverflowStrategy.fail) > > val wsr: WebSocketRequest =

[akka-user] Re: ('=') sign still not allowed in query string even with Uri.ParsingMode.Relaxed? (akka/akka#18479)

Sorry I had read the full discussion but I think I didn't correctly understand what is allowed in Akka, and what is RFC 3986 compliant. Now it's clearer for me - double "=" isn't even RFC 3986 compliant, so it shouldn't be allowed in the relaxed mode. I will try to add decent amount of examples

[akka-user] Re: Issue regarding AddressFromURIString and DNS hostnames

Interestingly, AddressFromURIString is also used in akka.cluster.ClusterSettings - and so seeding using DNS names with underscores in their hostnames is also problematic (especially as in my example use cases I don't have any control over the choice of the DNS name). Is this an intended design

[akka-user] Re: Issue regarding AddressFromURIString and DNS hostnames

Hi Johan, how curious. I'm using version 1.12.1 of docker and version 1.8.0 of docker-compose, so in looking at that specific ticket, I'd have expected it to be included? Having said that, I note that docker-compose has the open issue https://github.com/docker/compose/issues/3912 - so, as

[akka-user] Re: Issue regarding AddressFromURIString and DNS hostnames

Hi Carl, I think that underscore in a hostname actually is not valid, if you look at RFC 952, the definition host hostname boils down to: ::= [*[]] Which means a letter followed by zero or more letters, digits or hyphens ending with a letter or a digit. I think docker actually has been

[akka-user] Re: akka.http.scaladsl.model.Uri's apply() methods should still take charset and mode parameters?

Hi, Raised an issue akka-http#395 I didn't realize @2beaucoup was you ! It's great I could to talk to you here :) I guess it takes time for me to submit a PR, but hopefully I can still fix this a bit later. Thanks! 2016年10月12日水曜日 18時24分34秒 UTC+9

[akka-user] Simple beginner questions: Accessing values in flows

I have the following code: val cmdSrc: Source[Message, ActorRef] = Source.actorRef[Message](10, OverflowStrategy.fail) val wsr: WebSocketRequest = WebSocketRequest(myEndpoint) val webSocketFlow: Flow[Message, Message, Future[WebSocketUpgradeResponse]] = Http().webSocketClientFlow(wsr) val