Fixed the race condition in StreamingWebSocketClient...

made StopAsync and StartAsync thread-safe. Implemented the fix for Nethereum#738. Fixed the problem where the _listener task completed immediately. Also, the listener now quits when the WebSocket disconnects.
snake-4 · Nov 20, 2021 · ea6da1a · ea6da1a
1 parent 7a8e150
commit ea6da1a
Show file tree

Hide file tree

Showing 2 changed files with 128 additions and 189 deletions.
diff --git a/consoletests/Nethereum.WebSocketsStreamingTest/Program.cs b/consoletests/Nethereum.WebSocketsStreamingTest/Program.cs
@@ -130,10 +130,6 @@ public static async Task SubscribeAndRunAsync()
                 Console.WriteLine("Logs error info:" + exception.Message);
             });
 
-
-
-
-
             await client.StartAsync();
 
             blockHeaderSubscription.SubscribeAsync().Wait();
@@ -150,10 +146,10 @@ public static async Task SubscribeAndRunAsync()
 
             //await ethLogsTokenTransfer.SubscribeAsync(filterTransfers);
 
-            //Thread.Sleep(30000);
+            //await Task.Delay(30000);
             //pendingTransactionsSubscription.UnsubscribeAsync().Wait();
 
-            //Thread.Sleep(20000);
+            //await Task.Delay(20000);
 
             //blockHeaderSubscription.UnsubscribeAsync().Wait();
 
@@ -166,8 +162,6 @@ public static async Task SubscribeAndRunAsync()
         private static async void Client_Error(object sender, Exception ex)
         {
             Console.WriteLine("Client Error restarting...");
-           // ((StreamingWebSocketClient)sender).Error -= Client_Error;
-            ((StreamingWebSocketClient)sender).Dispose();
             await SubscribeAndRunAsync();
         }