diff --git a/src/KubernetesClient/Kubernetes.WebSocket.cs b/src/KubernetesClient/Kubernetes.WebSocket.cs
index 3d376f0..a3a5bc9 100644
--- a/src/KubernetesClient/Kubernetes.WebSocket.cs
+++ b/src/KubernetesClient/Kubernetes.WebSocket.cs
@@ -281,8 +281,7 @@ namespace k8s
             try
             {
                 BeforeRequest();
-                webSocket = await webSocketBuilder.BuildAndConnectAsync(uri, CancellationToken.None)
-                    .ConfigureAwait(false);
+                webSocket = await webSocketBuilder.BuildAndConnectAsync(uri, cancellationToken).ConfigureAwait(false);
             }
             catch (WebSocketException wse) when (wse.WebSocketErrorCode == WebSocketError.HeaderError ||
                                                  (wse.InnerException is WebSocketException &&