Waiting when disposing till the stop message was sent (#635)

Co-authored-by: kim <kim.bechtold@webfactory-i4.de>

Author: kimlukas

src/GraphQL.Client/Websocket/GraphQLTransportWSProtocolHandler.cs

@@ -116,7 +116,7 @@ public IObservable<GraphQLResponse<TResponse>> CreateSubscriptionObservable<TRes
 
             var disposable = new CompositeDisposable(
                 observable.Subscribe(observer),
-                Disposable.Create(async () =>
+                Disposable.Create(() =>
                 {
                     Debug.WriteLine($"disposing subscription {startRequest.Id}, websocket state is '{_webSocketHandler.WebSocketState}'");
                     // only try to send close request on open websocket
@@ -126,7 +126,7 @@ public IObservable<GraphQLResponse<TResponse>> CreateSubscriptionObservable<TRes
                     try
                     {
                         Debug.WriteLine($"sending stop message on subscription {startRequest.Id}");
-                        await _queueWebSocketRequest(stopRequest).ConfigureAwait(false);
+                        _queueWebSocketRequest(stopRequest).GetAwaiter().GetResult();
                     }
                     // do not break on disposing
                     catch (OperationCanceledException) { }

src/GraphQL.Client/Websocket/GraphQLWSProtocolHandler.cs

@@ -101,7 +101,7 @@ public IObservable<GraphQLResponse<TResponse>> CreateSubscriptionObservable<TRes
 
             var disposable = new CompositeDisposable(
                 observable.Subscribe(observer),
-                Disposable.Create(async () =>
+                Disposable.Create(() =>
                 {
                     Debug.WriteLine($"disposing subscription {startRequest.Id}, websocket state is '{_webSocketHandler.WebSocketState}'");
                     // only try to send close request on open websocket
@@ -111,7 +111,7 @@ public IObservable<GraphQLResponse<TResponse>> CreateSubscriptionObservable<TRes
                     try
                     {
                         Debug.WriteLine($"sending stop message on subscription {startRequest.Id}");
-                        await _queueWebSocketRequest(stopRequest).ConfigureAwait(false);
+                        _queueWebSocketRequest(stopRequest).GetAwaiter().GetResult();
                     }
                     // do not break on disposing
                     catch (OperationCanceledException) { }