From 6681418dd19657bcbc808a7858190da97e410930 Mon Sep 17 00:00:00 2001
From: Kim Lukas Bechtold <51699215+kimlukas@users.noreply.github.com>
Date: Mon, 22 Apr 2024 08:39:32 +0200
Subject: [PATCH] Waiting when disposing till the stop message was sent (#635)

Co-authored-by: kim <kim.bechtold@webfactory-i4.de>
---
 .../Websocket/GraphQLTransportWSProtocolHandler.cs            | 4 ++--
 src/GraphQL.Client/Websocket/GraphQLWSProtocolHandler.cs      | 4 ++--
 2 files changed, 4 insertions(+), 4 deletions(-)

diff --git a/src/GraphQL.Client/Websocket/GraphQLTransportWSProtocolHandler.cs b/src/GraphQL.Client/Websocket/GraphQLTransportWSProtocolHandler.cs
index 1ac5ffeb..2f3b28b0 100644
--- a/src/GraphQL.Client/Websocket/GraphQLTransportWSProtocolHandler.cs
+++ b/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) { }
diff --git a/src/GraphQL.Client/Websocket/GraphQLWSProtocolHandler.cs b/src/GraphQL.Client/Websocket/GraphQLWSProtocolHandler.cs
index 03efdba4..e08da57e 100644
--- a/src/GraphQL.Client/Websocket/GraphQLWSProtocolHandler.cs
+++ b/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) { }