Skip to content

Commit f6dc549

Browse files
committed
invoke SendWebSocketRequestAsync with Observable.FromAsync
1 parent bb7ea6c commit f6dc549

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

src/GraphQL.Client/Websocket/GraphQLHttpWebSocket.cs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -79,7 +79,7 @@ public GraphQLHttpWebSocket(Uri webSocketUri, GraphQLHttpClient client)
7979
IncomingMessageStream = GetMessageStream();
8080

8181
_requestSubscription = _requestSubject
82-
.Select(SendWebSocketRequestAsync)
82+
.Select(request => Observable.FromAsync(() => SendWebSocketRequestAsync(request)))
8383
.Concat()
8484
.Subscribe();
8585
}

0 commit comments

Comments
 (0)