Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- private readonly Dictionary<PID, object> _processedMessages = new Dictionary<PID, object>();
- public Task ReceiveAsync(IContext context)
- {
- switch (context.Message)
- {
- case Credit msg when _processedMessages.ContainsKey(msg.ReplyTo):
- replyTo.Tell(_processedMessages[replyTo]);
- return Actor.Done;
- case Credit msg:
- _balance += amount;
- _processedMessages.Add(replyTo, new OK());
- replyTo.Tell(new OK());
- return Actor.Done;
- //...
- }
- return Actor.Done;
- }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement