
                             d dl mZ d Zy)   )	ws_clientc                      fd} j                   j                  j                  }	 | j                   j                  _          |i || j                   j                  _        S # | j                   j                  _        w xY w)z%Stream given API call using websocketc                      	 j                   j                  j                  }t        j                  |g| i |S # t        $ r# j                   j                  j                  }Y Dw xY w)N)__self__
api_clientconfigurationAttributeErrorconfigr   websocket_call)argskwargsr
   funcs      +lib/third_party/kubernetes/stream/stream.py_intercept_request_callz'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   