Cancellation token testing.

Dtronix · Aug 24, 2023 · 46897b1 · 46897b1
1 parent bdbeb0e
commit 46897b1
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/src/NexNet/Internals/NexusSession.Sending.cs b/src/NexNet/Internals/NexusSession.Sending.cs
@@ -63,7 +63,7 @@ public async ValueTask SendMessage<TMessage>(TMessage body, CancellationToken ca
 
         Logger?.LogTrace($"Sending {TMessage.Type} header and  body with {length} total bytes.");
 
-        var result = await _pipeOutput.FlushAsync(cancellationToken).ConfigureAwait(false);
+        var result = await _pipeOutput.FlushAsync().ConfigureAwait(false);
 
         OnSent?.Invoke();
 
@@ -135,7 +135,7 @@ public async ValueTask SendHeaderWithBody(MessageType type, ReadOnlyMemory<byte>
         FlushResult result = default;
         try
         {
-            result = await _pipeOutput.FlushAsync(cancellationToken).ConfigureAwait(false);
+            result = await _pipeOutput.FlushAsync().ConfigureAwait(false);
         }
         catch (ObjectDisposedException)
         {
@@ -205,7 +205,7 @@ private async ValueTask SendHeaderCore(MessageType type, bool force, Cancellatio
         FlushResult result = default;
         try
         {
-            result = await _pipeOutput.FlushAsync(cancellationToken).ConfigureAwait(false);
+            result = await _pipeOutput.FlushAsync().ConfigureAwait(false);
         }
         catch (ObjectDisposedException)
         {