@Horusiath Akka.Persistence What I should have asked about the use of
protected readonly LinkedList<CancellationTokenSource> PendingOperations;
was why did you use a linkedlist instead of a normal List? Also I was thinking of abandoning what I was working on and build on top of Akka.Persistence and I was wondering how closely did you adhere to the JVM Akka? Do you think there is room to add support for projections or is there something there that I am not seeing that addresses this ? I have a use case that I think would be ideal for Akka.net but I need to Get a read model projected from the events. Basically a UI would feed click events at a rapid pace back to an actor for each current user session. That actor would persist the incoming event and once that value is stored a projection gets generated. I know this something that I can accomplish several ways but I wanted to be sure that I am not duplicating any effort.
//the task scheduler is active here even though it shouldnt be
private void Working()
{
Receive<ChildActor.ChildCompleted>(work =>
{
_askSource.Tell(new WorkFinished());
UnbecomeStacked();
});
}
protected override void QueueTask(Task task)
{
var s = CallContext.LogicalGetData(StateKey) as AmbientState; //<-- this fixes the issue, but thats a bad hack and I have no idea what consequences that has
if (task.AsyncState == Outer || s == null)
{
TryExecuteTask(task);
return;
}
<configSections>
<section name="statsD" type="NStatsD.StatsDConfigurationSection, NStatsD" />
</configSections>
<statsD enabled="true" prefix="dev.">
<server host="localhost" port="8125" />
</statsD>