Add RequestChannelException.

SaladLab · Jun 20, 2016 · 0c05545 · 0c05545
1 parent 74cfcf0
commit 0c05545
Show file tree

Hide file tree

Showing 2 changed files with 16 additions and 2 deletions.
diff --git a/core/Akka.Interfaced-Base/Exceptions.cs b/core/Akka.Interfaced-Base/Exceptions.cs
@@ -91,4 +91,19 @@ public RequestHaltException(string message, Exception innerException = null)
         {
         }
     }
+
+    /// <summary>
+    /// This exception is thrown when the channel used for communicating with an actor has a problem.
+    /// </summary>
+    public class RequestChannelException : AkkaInterfacedException
+    {
+        public RequestChannelException()
+        {
+        }
+
+        public RequestChannelException(string message, Exception innerException = null)
+            : base(message, innerException)
+        {
+        }
+    }
 }
diff --git a/core/Akka.Interfaced/InterfacedActor.RequestWaiter.cs b/core/Akka.Interfaced/InterfacedActor.RequestWaiter.cs
@@ -9,15 +9,14 @@ namespace Akka.Interfaced
 {
     internal class InterfacedActorRequestWaiter
     {
-        private int _lastRequestId;
-
         private struct ResponseWaitingItem
         {
             public Action<object, ResponseMessage> ResponseHandler;
             public Action<object> CancelHandler;
             public object TaskCompletionSource;
         }
 
+        private int _lastRequestId;
         private readonly ConcurrentDictionary<int, ResponseWaitingItem> _responseWaitingItems =
             new ConcurrentDictionary<int, ResponseWaitingItem>();