tests

Author: KSemenenko

ManagedCode.Orleans.SignalR.Core/Interfaces/IObserverConnectionManager.cs

@@ -6,10 +6,13 @@ namespace ManagedCode.Orleans.SignalR.Core.Interfaces;
 
 public interface IObserverConnectionManager : IGrain
 {
+    [AlwaysInterleave]
     Task AddConnection(string connectionId, ISignalRObserver observer);
 
+    [AlwaysInterleave]
     Task RemoveConnection(string connectionId, ISignalRObserver observer);
 
+    [AlwaysInterleave]
     [OneWay]
     Task Ping(ISignalRObserver observer);
 }

ManagedCode.Orleans.SignalR.Core/Interfaces/ISignalRConnectionCoordinatorGrain.cs

@@ -8,21 +8,28 @@ namespace ManagedCode.Orleans.SignalR.Core.Interfaces;
 public interface ISignalRConnectionCoordinatorGrain : IGrainWithStringKey
 {
     [ReadOnly]
+    [AlwaysInterleave]
     Task<int> GetPartitionCount();
 
     [ReadOnly]
+    [AlwaysInterleave]
     Task<int> GetPartitionForConnection(string connectionId);
 
+    [AlwaysInterleave]
     [OneWay]
     Task SendToAll(HubMessage message);
 
+    [AlwaysInterleave]
     [OneWay]
     Task SendToAllExcept(HubMessage message, string[] excludedConnectionIds);
 
+    [AlwaysInterleave]
     Task<bool> SendToConnection(HubMessage message, string connectionId);
 
+    [AlwaysInterleave]
     [OneWay]
     Task SendToConnections(HubMessage message, string[] connectionIds);
 
+    [AlwaysInterleave]
     Task NotifyConnectionRemoved(string connectionId);
 }

ManagedCode.Orleans.SignalR.Core/Interfaces/ISignalRConnectionHeartbeatGrain.cs

@@ -7,8 +7,10 @@ namespace ManagedCode.Orleans.SignalR.Core.Interfaces;
 
 public interface ISignalRConnectionHeartbeatGrain : IGrainWithStringKey
 {
+    [AlwaysInterleave]
     Task Start(ConnectionHeartbeatRegistration registration);
 
+    [AlwaysInterleave]
     [OneWay]
     Task Stop();
 }

ManagedCode.Orleans.SignalR.Core/Interfaces/ISignalRConnectionHolderGrain.cs

@@ -7,14 +7,18 @@ namespace ManagedCode.Orleans.SignalR.Core.Interfaces;
 
 public interface ISignalRConnectionHolderGrain : IGrainWithStringKey, IObserverConnectionManager
 {
+    [AlwaysInterleave]
     [OneWay]
     Task SendToAll(HubMessage message);
 
+    [AlwaysInterleave]
     [OneWay]
     Task SendToAllExcept(HubMessage message, string[] excludedConnectionIds);
 
+    [AlwaysInterleave]
     Task<bool> SendToConnection(HubMessage message, string connectionId);
 
+    [AlwaysInterleave]
     [OneWay]
     Task SendToConnections(HubMessage message, string[] connectionIds);
 }

ManagedCode.Orleans.SignalR.Core/Interfaces/ISignalRConnectionPartitionGrain.cs

@@ -7,14 +7,18 @@ namespace ManagedCode.Orleans.SignalR.Core.Interfaces;
 
 public interface ISignalRConnectionPartitionGrain : IGrainWithIntegerKey, IObserverConnectionManager
 {
+    [AlwaysInterleave]
     [OneWay]
     Task SendToPartition(HubMessage message);
 
+    [AlwaysInterleave]
     [OneWay]
     Task SendToPartitionExcept(HubMessage message, string[] excludedConnectionIds);
 
+    [AlwaysInterleave]
     Task<bool> SendToConnection(HubMessage message, string connectionId);
 
+    [AlwaysInterleave]
     [OneWay]
     Task SendToConnections(HubMessage message, string[] connectionIds);
 }

ManagedCode.Orleans.SignalR.Core/Interfaces/ISignalRGroupCoordinatorGrain.cs

@@ -8,25 +8,31 @@ namespace ManagedCode.Orleans.SignalR.Core.Interfaces;
 public interface ISignalRGroupCoordinatorGrain : IGrainWithStringKey
 {
     [ReadOnly]
+    [AlwaysInterleave]
     Task<int> GetPartitionCount();
 
     [ReadOnly]
+    [AlwaysInterleave]
     Task<int> GetPartitionForGroup(string groupName);
 
+    [AlwaysInterleave]
     [OneWay]
     Task SendToGroup(string groupName, HubMessage message);
 
+    [AlwaysInterleave]
     [OneWay]
     Task SendToGroupExcept(string groupName, HubMessage message, string[] excludedConnectionIds);
 
+    [AlwaysInterleave]
     [OneWay]
     Task SendToGroups(string[] groupNames, HubMessage message);
 
-    [OneWay]
+    [AlwaysInterleave]
     Task AddConnectionToGroup(string groupName, string connectionId, ISignalRObserver observer);
 
-    [OneWay]
+    [AlwaysInterleave]
     Task RemoveConnectionFromGroup(string groupName, string connectionId, ISignalRObserver observer);
 
+    [AlwaysInterleave]
     Task NotifyGroupRemoved(string groupName);
 }

ManagedCode.Orleans.SignalR.Core/Interfaces/ISignalRGroupGrain.cs

@@ -7,9 +7,11 @@ namespace ManagedCode.Orleans.SignalR.Core.Interfaces;
 
 public interface ISignalRGroupGrain : IGrainWithStringKey, IObserverConnectionManager
 {
+    [AlwaysInterleave]
     [OneWay]
     Task SendToGroup(HubMessage message);
 
+    [AlwaysInterleave]
     [OneWay]
     Task SendToGroupExcept(HubMessage message, string[] excludedConnectionIds);
 }

ManagedCode.Orleans.SignalR.Core/Interfaces/ISignalRGroupPartitionGrain.cs

@@ -7,21 +7,24 @@ namespace ManagedCode.Orleans.SignalR.Core.Interfaces;
 
 public interface ISignalRGroupPartitionGrain : IGrainWithIntegerKey, IObserverConnectionManager
 {
+    [AlwaysInterleave]
     [OneWay]
     Task SendToGroups(HubMessage message, string[] groupNames);
 
+    [AlwaysInterleave]
     [OneWay]
     Task SendToGroupsExcept(HubMessage message, string[] groupNames, string[] excludedConnectionIds);
 
-    [OneWay]
+    [AlwaysInterleave]
     Task AddConnectionToGroup(string groupName, string connectionId, ISignalRObserver observer);
 
-    [OneWay]
+    [AlwaysInterleave]
     Task RemoveConnectionFromGroup(string groupName, string connectionId, ISignalRObserver observer);
 
     [ReadOnly]
+    [AlwaysInterleave]
     Task<bool> HasConnection(string connectionId);
 
-    [OneWay]
+    [AlwaysInterleave]
     Task EnsureInitialized(string hubKey);
 }

ManagedCode.Orleans.SignalR.Core/Interfaces/ISignalRInvocationGrain.cs

@@ -8,14 +8,19 @@ namespace ManagedCode.Orleans.SignalR.Core.Interfaces;
 
 public interface ISignalRInvocationGrain : IGrainWithStringKey, IObserverConnectionManager
 {
+    [AlwaysInterleave]
     [OneWay]
     Task TryCompleteResult(string connectionId, HubMessage message);
 
+    [AlwaysInterleave]
     Task<ReturnType> TryGetReturnType();
 
+    [AlwaysInterleave]
     Task AddInvocation(ISignalRObserver? observer, InvocationInfo invocationInfo);
 
+    [AlwaysInterleave]
     Task<InvocationInfo?> RemoveInvocation();
 
+    [AlwaysInterleave]
     Task<CompletionMessage?> WaitForCompletion();
 }

ManagedCode.Orleans.SignalR.Core/Interfaces/ISignalRUserGrain.cs

@@ -7,9 +7,11 @@ namespace ManagedCode.Orleans.SignalR.Core.Interfaces;
 
 public interface ISignalRUserGrain : IGrainWithStringKey, IObserverConnectionManager
 {
+    [AlwaysInterleave]
     [OneWay]
     Task SendToUser(HubMessage message);
 
+    [AlwaysInterleave]
     [OneWay]
     Task RequestMessage();
 }