remove eventloop scheduler from send subscription

rose-a · rose-a · commit 3fa088ab614d · 2020-08-24T09:59:47.000+02:00
diff --git a/src/GraphQL.Client/Websocket/GraphQLHttpWebSocket.cs b/src/GraphQL.Client/Websocket/GraphQLHttpWebSocket.cs
@@ -84,8 +84,8 @@ public GraphQLHttpWebSocket(Uri webSocketUri, GraphQLHttpClient client)
                 Debug.WriteLine($"receive loop scheduler thread id: {Thread.CurrentThread.ManagedThreadId}"));
 
             _requestSubscription = _requestSubject
-                .ObserveOn(_sendLoopScheduler)
-                .SelectMany(SendWebSocketRequestAsync)
+                .Select(SendWebSocketRequestAsync)
+                .Concat()
                 .Subscribe();
         }
 

Original file line number	Diff line number	Diff line change
`@@ -84,8 +84,8 @@ public GraphQLHttpWebSocket(Uri webSocketUri, GraphQLHttpClient client)`
`84`	`84`	`Debug.WriteLine($"receive loop scheduler thread id: {Thread.CurrentThread.ManagedThreadId}"));`
`85`	`85`
`86`	`86`	`_requestSubscription = _requestSubject`
`87`		`- .ObserveOn(_sendLoopScheduler)`
`88`		`- .SelectMany(SendWebSocketRequestAsync)`
	`87`	`+ .Select(SendWebSocketRequestAsync)`
	`88`	`+ .Concat()`
`89`	`89`	`.Subscribe();`
`90`	`90`	`}`
`91`	`91`