@@ -16,7 +16,7 @@ namespace GraphQL.Client.Http
1616 public class GraphQLHttpClient : IGraphQLClient
1717 {
1818 private readonly Lazy < GraphQLHttpWebSocket > _lazyHttpWebSocket ;
19- private GraphQLHttpWebSocket _graphQlHttpWebSocket => _lazyHttpWebSocket . Value ;
19+ private GraphQLHttpWebSocket GraphQlHttpWebSocket => _lazyHttpWebSocket . Value ;
2020
2121 private readonly CancellationTokenSource _cancellationTokenSource = new CancellationTokenSource ( ) ;
2222 private readonly ConcurrentDictionary < Tuple < GraphQLRequest , Type > , object > _subscriptionStreams = new ConcurrentDictionary < Tuple < GraphQLRequest , Type > , object > ( ) ;
@@ -39,12 +39,12 @@ public class GraphQLHttpClient : IGraphQLClient
3939 /// <summary>
4040 /// Publishes all exceptions which occur inside the websocket receive stream (i.e. for logging purposes)
4141 /// </summary>
42- public IObservable < Exception > WebSocketReceiveErrors => _graphQlHttpWebSocket . ReceiveErrors ;
42+ public IObservable < Exception > WebSocketReceiveErrors => GraphQlHttpWebSocket . ReceiveErrors ;
4343
4444 /// <summary>
4545 /// the websocket connection state
4646 /// </summary>
47- public IObservable < GraphQLWebsocketConnectionState > WebsocketConnectionState => _graphQlHttpWebSocket . ConnectionState ;
47+ public IObservable < GraphQLWebsocketConnectionState > WebsocketConnectionState => GraphQlHttpWebSocket . ConnectionState ;
4848
4949 #region Constructors
5050
@@ -78,7 +78,7 @@ public async Task<GraphQLResponse<TResponse>> SendQueryAsync<TResponse>(GraphQLR
7878 if ( Options . UseWebSocketForQueriesAndMutations ||
7979 ! ( Options . WebSocketEndPoint is null ) && Options . EndPoint is null ||
8080 Options . EndPoint . HasWebSocketScheme ( ) )
81- return await _graphQlHttpWebSocket . SendRequest < TResponse > ( request , cancellationToken ) ;
81+ return await GraphQlHttpWebSocket . SendRequest < TResponse > ( request , cancellationToken ) ;
8282
8383 return await SendHttpRequestAsync < TResponse > ( request , cancellationToken ) ;
8484 }
@@ -99,7 +99,7 @@ public IObservable<GraphQLResponse<TResponse>> CreateSubscriptionStream<TRespons
9999 if ( _subscriptionStreams . ContainsKey ( key ) )
100100 return ( IObservable < GraphQLResponse < TResponse > > ) _subscriptionStreams [ key ] ;
101101
102- var observable = _graphQlHttpWebSocket . CreateSubscriptionStream < TResponse > ( request ) ;
102+ var observable = GraphQlHttpWebSocket . CreateSubscriptionStream < TResponse > ( request ) ;
103103
104104 _subscriptionStreams . TryAdd ( key , observable ) ;
105105 return observable ;
@@ -116,7 +116,7 @@ public IObservable<GraphQLResponse<TResponse>> CreateSubscriptionStream<TRespons
116116 if ( _subscriptionStreams . ContainsKey ( key ) )
117117 return ( IObservable < GraphQLResponse < TResponse > > ) _subscriptionStreams [ key ] ;
118118
119- var observable = _graphQlHttpWebSocket . CreateSubscriptionStream < TResponse > ( request , exceptionHandler ) ;
119+ var observable = GraphQlHttpWebSocket . CreateSubscriptionStream < TResponse > ( request , exceptionHandler ) ;
120120 _subscriptionStreams . TryAdd ( key , observable ) ;
121121 return observable ;
122122 }
@@ -127,7 +127,7 @@ public IObservable<GraphQLResponse<TResponse>> CreateSubscriptionStream<TRespons
127127 /// explicitly opens the websocket connection. Will be closed again on disposing the last subscription
128128 /// </summary>
129129 /// <returns></returns>
130- public Task InitializeWebsocketConnection ( ) => _graphQlHttpWebSocket . InitializeWebSocket ( ) ;
130+ public Task InitializeWebsocketConnection ( ) => GraphQlHttpWebSocket . InitializeWebSocket ( ) ;
131131
132132 #region Private Methods
133133
0 commit comments