Remove obsolete methods from Akka.Event and Akka.Dispatch

Arkatufus · Feb 27, 2023 · fd00547 · fd00547
1 parent 76b1e80
commit fd00547
Show file tree

Hide file tree

Showing 5 changed files with 0 additions and 32 deletions.
diff --git a/src/core/Akka.API.Tests/verify/CoreAPISpec.ApproveCore.Core.verified.txt b/src/core/Akka.API.Tests/verify/CoreAPISpec.ApproveCore.Core.verified.txt
@@ -2817,9 +2817,6 @@ namespace Akka.Dispatch.MessageQueues
     }
     public class UnboundedPriorityMessageQueue : Akka.Dispatch.MessageQueues.BlockingMessageQueue, Akka.Dispatch.IDequeBasedMessageQueueSemantics, Akka.Dispatch.ISemantics, Akka.Dispatch.IUnboundedDequeBasedMessageQueueSemantics, Akka.Dispatch.IUnboundedMessageQueueSemantics
     {
-        [System.ObsoleteAttribute("Use UnboundedPriorityMessageQueue(Func<object, int> priorityGenerator, int initia" +
-            "lCapacity) instead. [1.1.3]")]
-        public UnboundedPriorityMessageQueue(int initialCapacity) { }
         public UnboundedPriorityMessageQueue(System.Func<object, int> priorityGenerator, int initialCapacity) { }
         protected override int LockedCount { get; }
         public void EnqueueFirst(Akka.Actor.Envelope envelope) { }
@@ -3063,8 +3060,6 @@ namespace Akka.Event
     public class EventStream : Akka.Event.LoggingBus
     {
         public EventStream(bool debug) { }
-        [System.ObsoleteAttribute("Should be removed in 1.5")]
-        public bool InitUnsubscriber(Akka.Actor.IActorRef unsubscriber, Akka.Actor.ActorSystem system) { }
         public void StartUnsubscriber(Akka.Actor.Internal.ActorSystemImpl system) { }
         public override bool Subscribe(Akka.Actor.IActorRef subscriber, System.Type channel) { }
         public override bool Unsubscribe(Akka.Actor.IActorRef subscriber, System.Type channel) { }

diff --git a/src/core/Akka.API.Tests/verify/CoreAPISpec.ApproveCore.DotNet.verified.txt b/src/core/Akka.API.Tests/verify/CoreAPISpec.ApproveCore.DotNet.verified.txt
@@ -2822,9 +2822,6 @@ namespace Akka.Dispatch.MessageQueues
     }
     public class UnboundedPriorityMessageQueue : Akka.Dispatch.MessageQueues.BlockingMessageQueue, Akka.Dispatch.IDequeBasedMessageQueueSemantics, Akka.Dispatch.ISemantics, Akka.Dispatch.IUnboundedDequeBasedMessageQueueSemantics, Akka.Dispatch.IUnboundedMessageQueueSemantics
     {
-        [System.ObsoleteAttribute("Use UnboundedPriorityMessageQueue(Func<object, int> priorityGenerator, int initia" +
-            "lCapacity) instead. [1.1.3]")]
-        public UnboundedPriorityMessageQueue(int initialCapacity) { }
         public UnboundedPriorityMessageQueue(System.Func<object, int> priorityGenerator, int initialCapacity) { }
         protected override int LockedCount { get; }
         public void EnqueueFirst(Akka.Actor.Envelope envelope) { }
@@ -3068,8 +3065,6 @@ namespace Akka.Event
     public class EventStream : Akka.Event.LoggingBus
     {
         public EventStream(bool debug) { }
-        [System.ObsoleteAttribute("Should be removed in 1.5")]
-        public bool InitUnsubscriber(Akka.Actor.IActorRef unsubscriber, Akka.Actor.ActorSystem system) { }
         public void StartUnsubscriber(Akka.Actor.Internal.ActorSystemImpl system) { }
         public override bool Subscribe(Akka.Actor.IActorRef subscriber, System.Type channel) { }
         public override bool Unsubscribe(Akka.Actor.IActorRef subscriber, System.Type channel) { }

diff --git a/src/core/Akka.API.Tests/verify/CoreAPISpec.ApproveCore.Net.verified.txt b/src/core/Akka.API.Tests/verify/CoreAPISpec.ApproveCore.Net.verified.txt
@@ -2817,9 +2817,6 @@ namespace Akka.Dispatch.MessageQueues
     }
     public class UnboundedPriorityMessageQueue : Akka.Dispatch.MessageQueues.BlockingMessageQueue, Akka.Dispatch.IDequeBasedMessageQueueSemantics, Akka.Dispatch.ISemantics, Akka.Dispatch.IUnboundedDequeBasedMessageQueueSemantics, Akka.Dispatch.IUnboundedMessageQueueSemantics
     {
-        [System.ObsoleteAttribute("Use UnboundedPriorityMessageQueue(Func<object, int> priorityGenerator, int initia" +
-            "lCapacity) instead. [1.1.3]")]
-        public UnboundedPriorityMessageQueue(int initialCapacity) { }
         public UnboundedPriorityMessageQueue(System.Func<object, int> priorityGenerator, int initialCapacity) { }
         protected override int LockedCount { get; }
         public void EnqueueFirst(Akka.Actor.Envelope envelope) { }
@@ -3063,8 +3060,6 @@ namespace Akka.Event
     public class EventStream : Akka.Event.LoggingBus
     {
         public EventStream(bool debug) { }
-        [System.ObsoleteAttribute("Should be removed in 1.5")]
-        public bool InitUnsubscriber(Akka.Actor.IActorRef unsubscriber, Akka.Actor.ActorSystem system) { }
         public void StartUnsubscriber(Akka.Actor.Internal.ActorSystemImpl system) { }
         public override bool Subscribe(Akka.Actor.IActorRef subscriber, System.Type channel) { }
         public override bool Unsubscribe(Akka.Actor.IActorRef subscriber, System.Type channel) { }

diff --git a/src/core/Akka/Dispatch/MessageQueues/UnboundedPriorityMessageQueue.cs b/src/core/Akka/Dispatch/MessageQueues/UnboundedPriorityMessageQueue.cs
@@ -21,16 +21,6 @@ public class UnboundedPriorityMessageQueue : BlockingMessageQueue, IUnboundedDeq
         // doesn't need to be threadsafe - only called from within actor
         private readonly Stack<Envelope> _prependBuffer = new Stack<Envelope>();
 
-        /// <summary>
-        /// DEPRECATED. Use <see cref="UnboundedPriorityMessageQueue(Func{object,int}, int)"/> instead.
-        /// </summary>
-        /// <param name="initialCapacity">The initial capacity of the priority queue.</param>
-        [Obsolete("Use UnboundedPriorityMessageQueue(Func<object, int> priorityGenerator, int initialCapacity) instead. [1.1.3]")]
-        public UnboundedPriorityMessageQueue(int initialCapacity) : this(ListPriorityQueue.DefaultPriorityCalculator, initialCapacity)
-        {
-
-        }
-
         /// <summary>
         /// Creates a new unbounded priority message queue.
         /// </summary>

diff --git a/src/core/Akka/Event/EventStream.cs b/src/core/Akka/Event/EventStream.cs
@@ -148,13 +148,6 @@ public void StartUnsubscriber(ActorSystemImpl system)
             }
         }
 
-        [Obsolete("Should be removed in 1.5")]
-        public bool InitUnsubscriber(IActorRef unsubscriber, ActorSystem system)
-        {
-            StartUnsubscriber((ActorSystemImpl)system);
-            return true;
-        }
-
         private void RegisterWithUnsubscriber(IActorRef subscriber)
         {
             if (_unsubscriber.Value.IsNobody())