Skip to content

Commit b838003

Browse files
authored
Merge pull request #271 from graphql-dotnet/fix-270
invoke SendWebSocketRequestAsync with Observable.FromAsync
2 parents bb7ea6c + f6dc549 commit b838003

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)