use Failure to programmatically cancel Ask (#5187)

* close #3019 - use `Failure` to programmatically cancel `Ask` * added `SendSystemMessage` call back
akkadotnet · Aug 10, 2021 · 6b4a913 · 6b4a913
1 parent 0673dc3
commit 6b4a913
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/src/core/Akka/Actor/ActorRef.cs b/src/core/Akka/Actor/ActorRef.cs
@@ -134,6 +134,10 @@ protected override void TellInternal(object message, IActorRef sender)
                     {
                         _result.TrySetResult(t);
                     }
+                    else if (message is Failure f)
+                    {
+                        _result.TrySetException(f.Exception ?? new TaskCanceledException("Task cancelled by actor via Failure message."));
+                    }
                     else
                     {
                         _result.TrySetException(new ArgumentException(
@@ -142,7 +146,7 @@ protected override void TellInternal(object message, IActorRef sender)
                 }
             }
         }
-
+        
         /// <summary>
         /// TBD
         /// </summary>