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();
         }