
                             S SK Jr  S rg)   )	ws_clientc                   ^  U 4S jnT R                   R                  R                  n UT R                   R                  l        T " U0 UD6UT R                   R                  l        $ ! UT R                   R                  l        f = f)z%Stream given API call using websocketc                     >  TR                   R                  R                  n[
        R                  " U/U Q70 UD6$ ! [         a#    TR                   R                  R                  n NFf = f)N)__self__
api_clientconfigurationAttributeErrorconfigr   websocket_call)argskwargsr
   funcs      +lib/third_party/kubernetes/stream/stream.py_intercept_request_call'stream.<locals>._intercept_request_call   s`    /}}''55f ##F<T<V<<  /}}''..f/s    = *A*)A*)r   r   request)r   r   r   r   prev_requests   `    r   streamr      sh    = ))11,4'>DMM$  '3DMM$|DMM$s   "A' 'BN) r   r        r   <module>r      s   " 4r   