@@ -66,7 +66,7 @@ public GraphQLHttpClient(GraphQLHttpClientOptions options, HttpClient httpClient
6666 /// <inheritdoc />
6767 public Task < GraphQLResponse < TResponse > > SendQueryAsync < TResponse > ( GraphQLRequest request , CancellationToken cancellationToken = default ) {
6868 return Options . UseWebSocketForQueriesAndMutations
69- ? this . graphQlHttpWebSocket . SendRequest < TResponse > ( request , this , cancellationToken )
69+ ? this . graphQlHttpWebSocket . SendRequest < TResponse > ( request , cancellationToken )
7070 : this . SendHttpPostRequestAsync < TResponse > ( request , cancellationToken ) ;
7171 }
7272
@@ -85,7 +85,7 @@ public IObservable<GraphQLResponse<TResponse>> CreateSubscriptionStream<TRespons
8585 if ( subscriptionStreams . ContainsKey ( key ) )
8686 return ( IObservable < GraphQLResponse < TResponse > > ) subscriptionStreams [ key ] ;
8787
88- var observable = graphQlHttpWebSocket . CreateSubscriptionStream < TResponse > ( request , this , cancellationToken : cancellationTokenSource . Token ) ;
88+ var observable = graphQlHttpWebSocket . CreateSubscriptionStream < TResponse > ( request ) ;
8989
9090 subscriptionStreams . TryAdd ( key , observable ) ;
9191 return observable ;
@@ -101,7 +101,7 @@ public IObservable<GraphQLResponse<TResponse>> CreateSubscriptionStream<TRespons
101101 if ( subscriptionStreams . ContainsKey ( key ) )
102102 return ( IObservable < GraphQLResponse < TResponse > > ) subscriptionStreams [ key ] ;
103103
104- var observable = graphQlHttpWebSocket . CreateSubscriptionStream < TResponse > ( request , this , exceptionHandler , cancellationTokenSource . Token ) ;
104+ var observable = graphQlHttpWebSocket . CreateSubscriptionStream < TResponse > ( request , exceptionHandler ) ;
105105 subscriptionStreams . TryAdd ( key , observable ) ;
106106 return observable ;
107107 }
0 commit comments