add temporary double join/leave safeguard (to be deprecated with EE i…

…mplementation)
pubnub · Feb 20, 2025 · db338eb · db338eb
1 parent 0fdc375
commit db338eb
Showing 1 changed file with 16 additions and 0 deletions.
diff --git a/c-sharp-chat/PubnubChatApi/PubnubChatApi/Entities/Channel.cs b/c-sharp-chat/PubnubChatApi/PubnubChatApi/Entities/Channel.cs
@@ -557,6 +557,10 @@ public MessageDraft CreateMessageDraft(UserSuggestionSource userSuggestionSource
         /// <seealso cref="Join"/>
         public async Task Connect()
         {
+            if (connected)
+            {
+                return;
+            }
             connected = true;
             var buffer = new StringBuilder(4096);
             CUtilities.CheckCFunctionResult(await Task.Run(() => pn_channel_connect(pointer, buffer)));
@@ -588,6 +592,10 @@ public async Task Connect()
         /// <seealso cref="Disconnect"/>
         public async Task Join()
         {
+            if (connected)
+            {
+                return;
+            }
             connected = true;
             var buffer = new StringBuilder(4096);
             CUtilities.CheckCFunctionResult(await Task.Run(() => pn_channel_join(pointer, string.Empty, buffer)));
@@ -614,6 +622,10 @@ public async Task Join()
         /// <seealso cref="Join"/>
         public async Task Disconnect()
         {
+            if (!connected)
+            {
+                return;
+            }
             connected = false;
             var buffer = new StringBuilder(4096);
             CUtilities.CheckCFunctionResult(await Task.Run(() => pn_channel_disconnect(pointer, buffer)));
@@ -642,6 +654,10 @@ public async Task Disconnect()
         /// <seealso cref="Disconnect"/>
         public async Task Leave()
         {
+            if (!connected)
+            {
+                return;
+            }
             connected = false;
             var buffer = new StringBuilder(4096);
             CUtilities.CheckCFunctionResult(await Task.Run(() => pn_channel_leave(pointer, buffer)));