
    =Ki	                         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                    U(       a  UR                  5        H	  u  pVXdU'   M     UR                  R                  n UR                  nUR                  n	UR                  SS5      n
 [        R                  " XU
S9Ul        U" U0 UD6nU
(       aI  UR                  SS5      (       a2  USS R                  S5      R                  S	5      R                  S5      nUXl        $ ! [         a    UR
                  n Nf = 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.binaryF)r   _preload_contentT   latin1unicode_escape)items__self__
api_clientconfigurationAttributeErrorconfigrequestpop	functoolspartialgetencodedecode)websocket_requestforce_kwargs
api_methodargskwargskwargvaluer   r   prev_requestr   outs               Z/var/www/html/dynamic-report/venv/lib/python3.13/site-packages/kubernetes/stream/stream.py_websocket_requestr#      s     (..0LE!5M 1$$//J*"00 %%LZZ%(F*&../@X^_
$)&) fjj!3T::a)""8,334DELLXVC)!  *"))*  *s   C! 'A3C= !C:9C:=Dr   F)	r    r   r#   r   websocket_callstreamportforward_callportforward     r"   <module>r+      sQ     *: 
		-y/G/G	N 2I4N4NQcdiPjkr*   