Skip to content

Commit

Permalink
Revert "Make HandleActorTaskSchedulerMessage method `protected virt…
Browse files Browse the repository at this point in the history
…ual` (#6763)" (#6766)

This reverts commit 1345e58.

Co-authored-by: Aaron Stannard <[email protected]>
  • Loading branch information
Arkatufus and Aaronontheweb authored May 17, 2023
1 parent c514fd1 commit d7304f4
Show file tree
Hide file tree
Showing 4 changed files with 2 additions and 29 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -100,8 +100,6 @@ namespace Akka.Actor
public static Akka.Actor.IActorRef GetCurrentSelfOrNoSender() { }
public static Akka.Actor.IActorRef GetCurrentSenderOrNoSender() { }
public Akka.Actor.IInternalActorRef GetSingleChild(string name) { }
[Akka.Annotations.InternalApiAttribute()]
protected virtual void HandleActorTaskSchedulerMessage(Akka.Dispatch.SysMsg.ActorTaskSchedulerMessage m) { }
public void Init(bool sendSupervise, Akka.Dispatch.MailboxType mailboxType) { }
public Akka.Actor.Internal.ChildRestartStats InitChild(Akka.Actor.IInternalActorRef actor) { }
public void Invoke(Akka.Actor.Envelope envelope) { }
Expand Down Expand Up @@ -3129,16 +3127,6 @@ namespace Akka.Dispatch.SysMsg
public ActorTask(System.Threading.Tasks.Task task) { }
public System.Threading.Tasks.Task Task { get; }
}
[Akka.Annotations.InternalApiAttribute()]
public sealed class ActorTaskSchedulerMessage : Akka.Dispatch.SysMsg.SystemMessage
{
public ActorTaskSchedulerMessage(Akka.Dispatch.ActorTaskScheduler scheduler, System.Threading.Tasks.Task task, object message) { }
public ActorTaskSchedulerMessage(System.Exception exception, object message) { }
public System.Exception Exception { get; }
public object Message { get; }
public void ExecuteTask() { }
public override string ToString() { }
}
public sealed class Create : Akka.Dispatch.SysMsg.SystemMessage
{
public Create(Akka.Actor.ActorInitializationException failure = null) { }
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -100,8 +100,6 @@ namespace Akka.Actor
public static Akka.Actor.IActorRef GetCurrentSelfOrNoSender() { }
public static Akka.Actor.IActorRef GetCurrentSenderOrNoSender() { }
public Akka.Actor.IInternalActorRef GetSingleChild(string name) { }
[Akka.Annotations.InternalApiAttribute()]
protected virtual void HandleActorTaskSchedulerMessage(Akka.Dispatch.SysMsg.ActorTaskSchedulerMessage m) { }
public void Init(bool sendSupervise, Akka.Dispatch.MailboxType mailboxType) { }
public Akka.Actor.Internal.ChildRestartStats InitChild(Akka.Actor.IInternalActorRef actor) { }
public void Invoke(Akka.Actor.Envelope envelope) { }
Expand Down Expand Up @@ -3121,16 +3119,6 @@ namespace Akka.Dispatch.SysMsg
public ActorTask(System.Threading.Tasks.Task task) { }
public System.Threading.Tasks.Task Task { get; }
}
[Akka.Annotations.InternalApiAttribute()]
public sealed class ActorTaskSchedulerMessage : Akka.Dispatch.SysMsg.SystemMessage
{
public ActorTaskSchedulerMessage(Akka.Dispatch.ActorTaskScheduler scheduler, System.Threading.Tasks.Task task, object message) { }
public ActorTaskSchedulerMessage(System.Exception exception, object message) { }
public System.Exception Exception { get; }
public object Message { get; }
public void ExecuteTask() { }
public override string ToString() { }
}
public sealed class Create : Akka.Dispatch.SysMsg.SystemMessage
{
public Create(Akka.Actor.ActorInitializationException failure = null) { }
Expand Down
4 changes: 1 addition & 3 deletions src/core/Akka/Actor/ActorCell.DefaultMessages.cs
Original file line number Diff line number Diff line change
Expand Up @@ -14,7 +14,6 @@
using Akka.Event;
using Debug = Akka.Event.Debug;
using System.Globalization;
using Akka.Annotations;

namespace Akka.Actor
{
Expand Down Expand Up @@ -335,8 +334,7 @@ internal void SystemInvoke(ISystemMessage envelope)
SysMsgInvokeAll(new EarliestFirstSystemMessageList((SystemMessage)envelope), CalculateState());
}

[InternalApi]
protected virtual void HandleActorTaskSchedulerMessage(ActorTaskSchedulerMessage m)
private void HandleActorTaskSchedulerMessage(ActorTaskSchedulerMessage m)
{
//set the current message captured in the async operation
//current message was cleared earlier when the async receive handler completed
Expand Down
3 changes: 1 addition & 2 deletions src/core/Akka/Dispatch/SysMsg/ISystemMessage.cs
Original file line number Diff line number Diff line change
Expand Up @@ -588,8 +588,7 @@ public ActorTask(Task task)
/// <summary>
/// TBD
/// </summary>
[InternalApi]
public sealed class ActorTaskSchedulerMessage : SystemMessage
internal sealed class ActorTaskSchedulerMessage : SystemMessage
{
private readonly ActorTaskScheduler _scheduler;
private readonly Task _task;
Expand Down

0 comments on commit d7304f4

Please sign in to comment.