
    Iiq                         S SK r SSKJr  S r\ R                  " \\R
                  S5      r\ R                  " \\R                  SS05      rg)    N   )	ws_clientc                 J   U(       a  UR                  5        H	  u  pVXdU'   M     UR                  R                  n UR                  nUR                  n	 [        R                  " X5      Ul        U" U0 UD6Xl        $ ! [         a    UR
                  n NNf = f! Xl        f = f)zOverride the ApiClient.request method with an alternative websocket based
method and call the supplied Kubernetes API method with that in place.)	items__self__
api_clientconfigurationAttributeErrorconfigrequest	functoolspartial)
websocket_requestforce_kwargs
api_methodargskwargskwargvaluer   r	   prev_requests
             >/venv/lib/python3.13/site-packages/kubernetes/stream/stream.py_websocket_requestr      s     (..0LE!5M 1$$//J*"00 %%L*&../@P
4*6*)  *"))* *s   A> "B >BBB"_preload_contentF)	r    r   r   r   websocket_callstreamportforward_callportforward     r   <module>r!      sQ     *( 
		-y/G/G	N 2I4N4NQcdiPjkr    