From f6dc549f3fd0ec304fd10f56334dd24b308608c3 Mon Sep 17 00:00:00 2001
From: Alexander Rose <arose@haprotec.de>
Date: Thu, 27 Aug 2020 08:55:02 +0200
Subject: [PATCH] invoke SendWebSocketRequestAsync with Observable.FromAsync

---
 src/GraphQL.Client/Websocket/GraphQLHttpWebSocket.cs | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/src/GraphQL.Client/Websocket/GraphQLHttpWebSocket.cs b/src/GraphQL.Client/Websocket/GraphQLHttpWebSocket.cs
index b61ab9b9..663a7f0d 100644
--- a/src/GraphQL.Client/Websocket/GraphQLHttpWebSocket.cs
+++ b/src/GraphQL.Client/Websocket/GraphQLHttpWebSocket.cs
@@ -79,7 +79,7 @@ public GraphQLHttpWebSocket(Uri webSocketUri, GraphQLHttpClient client)
             IncomingMessageStream = GetMessageStream();
 
             _requestSubscription = _requestSubject
-                .Select(SendWebSocketRequestAsync)
+                .Select(request => Observable.FromAsync(() => SendWebSocketRequestAsync(request)))
                 .Concat()
                 .Subscribe();
         }