fix: ConcurrentDictionaryGroup has no WriteToAsync (single target) im…

…plementation.
Cysharp · Dec 13, 2019 · dc3d855 · dc3d855
1 parent fe76ca0
commit dc3d855
Showing 1 changed file with 14 additions and 1 deletion.
diff --git a/src/MagicOnion/Server/Hubs/Group.ConcurrentDictionary.cs b/src/MagicOnion/Server/Hubs/Group.ConcurrentDictionary.cs
@@ -208,7 +208,20 @@ public Task WriteExceptAsync<T>(int methodId, T value, Guid[] connectionIds, boo
 
         public Task WriteToAsync<T>(int methodId, T value, Guid connectionId, bool fireAndForget)
         {
-            throw new NotImplementedException();
+            var message = BuildMessage(methodId, value);
+            if (fireAndForget)
+            {
+                if (members.TryGetValue(connectionId, out var context))
+                {
+                    WriteInAsyncLockVoid(context, message);
+                    logger.InvokeHubBroadcast(GroupName, message.Length, 1);
+                }
+                return TaskEx.CompletedTask;
+            }
+            else
+            {
+                throw new NotSupportedException("The write operation must be called with Fire and Forget option");
+            }
         }
 
         public Task WriteToAsync<T>(int methodId, T value, Guid[] connectionIds, bool fireAndForget)