diff --git a/kubernetes_asyncio/stream/ws_client.py b/kubernetes_asyncio/stream/ws_client.py
index <HASH>..<HASH> 100644
--- a/kubernetes_asyncio/stream/ws_client.py
+++ b/kubernetes_asyncio/stream/ws_client.py
@@ -63,10 +63,12 @@ class WsApiClient(ApiClient):
         if query_params:
             url += '?' + urlencode(query_params)
 
+        url = get_websocket_url(url)
+
         if _preload_content:
 
             resp_all = ''
-            async with self.rest_client.pool_manager.ws_connect(url) as ws:
+            async with self.rest_client.pool_manager.ws_connect(url, headers=headers) as ws:
                 async for msg in ws:
                     msg = msg.data.decode('utf-8')[1:]
                     resp_all += msg
stream: add headers and ws proto