Fix for earlier platforms.

Gremlinq · Nov 13, 2023 · 07cdaca · 07cdaca
1 parent 53f5d75
commit 07cdaca
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/src/Providers.Core/Factory/WebSocketGremlinqClientFactory.cs b/src/Providers.Core/Factory/WebSocketGremlinqClientFactory.cs
@@ -126,7 +126,7 @@ private record struct ResponseMessageEnvelope(Guid? RequestId, ResponseStatus? S
                 private readonly SemaphoreSlim _sendLock = new(1);
                 private readonly CancellationTokenSource _cts = new();
                 private readonly IGremlinQueryEnvironment _environment;
-                private readonly TaskCompletionSource _startTcs = new();
+                private readonly TaskCompletionSource<int> _startTcs = new();
                 private readonly ConcurrentDictionary<Guid, Channel> _channels = new();
 
                 public WebSocketGremlinqClient(GremlinServer server, Action<ClientWebSocketOptions> optionsTransformation, IGremlinQueryEnvironment environment)
@@ -232,7 +232,7 @@ private async Task SendCore(RequestMessage requestMessage, CancellationToken ct)
                         if (_client.State == WebSocketState.None)
                         {
                             await _client.ConnectAsync(_server.Uri, ct);
-                            _startTcs.TrySetResult();
+                            _startTcs.TrySetResult(0);
                         }
 
                         if (_environment.Serializer.TryTransform(requestMessage, _environment, out byte[]? serializedRequest))