Add self param to RunTask.

SaladLab · Jun 23, 2016 · fd47d8e · fd47d8e
1 parent ebba595
commit fd47d8e
Showing 1 changed file with 6 additions and 6 deletions.
diff --git a/core/Akka.Interfaced/InterfacedActor.cs b/core/Akka.Interfaced/InterfacedActor.cs
@@ -535,23 +535,23 @@ Task<TReturn> IRequestWaiter.SendRequestAndReceive<TReturn>(IRequestTarget targe
 
         // async support
 
-        protected new void RunTask(Action action)
+        protected void RunTask(Action action, IActorRef self = null)
         {
             RunTask(() =>
             {
                 action();
                 return Task.FromResult(0);
-            });
+            }, self);
         }
 
-        protected new void RunTask(Func<Task> function)
+        protected void RunTask(Func<Task> function, IActorRef self = null)
         {
-            RunTask(function, false);
+            RunTask(function, false, self);
         }
 
-        protected void RunTask(Func<Task> function, bool isReentrant)
+        protected void RunTask(Func<Task> function, bool isReentrant, IActorRef self = null)
         {
-            Self.Tell(new TaskRunMessage { Function = function, IsReentrant = isReentrant });
+            (self ?? Self).Tell(new TaskRunMessage { Function = function, IsReentrant = isReentrant });
         }
 
         // other messages