Small fixes to parsing notifications from streaming client.

bmresearch · May 23, 2021 · 3e4837b · 3e4837b
1 parent 675736f
commit 3e4837b
Showing 1 changed file with 1 addition and 6 deletions.
diff --git a/src/Solnet.Rpc/Core/Sockets/SolanaStreamingClient.cs b/src/Solnet.Rpc/Core/Sockets/SolanaStreamingClient.cs
@@ -106,8 +106,7 @@ private async Task ReadNextMessage(CancellationToken cancellationToken = default
 
         private void HandleNewMessage(Memory<byte> mem)
         {
-            JsonReaderOptions opts = new JsonReaderOptions() { MaxDepth = 1 };
-            Utf8JsonReader asd = new Utf8JsonReader(mem.Span, opts);
+            Utf8JsonReader asd = new Utf8JsonReader(mem.Span);
 
             asd.Read();
 
@@ -120,13 +119,9 @@ private void HandleNewMessage(Memory<byte> mem)
                 {
                     case JsonTokenType.PropertyName:
                         prop = asd.GetString();
-                        break;
-                    case JsonTokenType.StartObject:
                         if (prop == "params")
                         {
                             HandleDataMessage(ref asd, method);
-                            // 
-                            //
                         }
                         break;
                     case JsonTokenType.String: