Skip to content

Commit

Permalink
cleanup
Browse files Browse the repository at this point in the history
  • Loading branch information
zbynek001 committed May 9, 2019
1 parent 42b490b commit 6b5b988
Showing 1 changed file with 2 additions and 2 deletions.
4 changes: 2 additions & 2 deletions src/core/Akka/Actor/Scheduler/TimerScheduler.cs
Original file line number Diff line number Diff line change
Expand Up @@ -193,9 +193,9 @@ private void StartTimer(string key, object msg, TimeSpan timeout, TimeSpan initi

ICancelable task;
if (repeat)
task = ctx.System.Scheduler.ScheduleTellRepeatedlyCancelable(initialDelay, timeout, ctx.Self, timerMsg, ActorRefs.NoSender);// (ctx.dispatcher)
task = ctx.System.Scheduler.ScheduleTellRepeatedlyCancelable(initialDelay, timeout, ctx.Self, timerMsg, ActorRefs.NoSender);
else
task = ctx.System.Scheduler.ScheduleTellOnceCancelable(timeout, ctx.Self, timerMsg, ActorRefs.NoSender);// (ctx.dispatcher)
task = ctx.System.Scheduler.ScheduleTellOnceCancelable(timeout, ctx.Self, timerMsg, ActorRefs.NoSender);

var nextTimer = new Timer(key, msg, repeat, nextGen, task);
ctx.System.Log.Debug("Start timer [{0}] with generation [{1}]", key, timerGen);
Expand Down

0 comments on commit 6b5b988

Please sign in to comment.