We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
CounterActor
1 parent 395abea commit d89096fCopy full SHA for d89096f
unit-0/completed/AkkaWordCounter/CounterActor.cs
@@ -44,10 +44,12 @@ protected override void OnReceive(object message){
44
_subscribers.Clear();
45
break;
46
}
47
- case FetchCounts when _doneCounting:
+ case FetchCounts fetchCounts when _doneCounting:
48
+ {
49
// instantly reply with the results
- Sender.Tell(_tokenCounts.ToImmutableDictionary());
50
+ fetchCounts.Subscriber.Tell(_tokenCounts.ToImmutableDictionary());
51
52
+ }
53
case FetchCounts fetch:
54
{
55
_subscribers.Add(fetch.Subscriber);
0 commit comments