o Rh @sDddlZddlmZddZeeejdZeeejddiZdS)N) ws_clientc Os|r|D]\}}|||<q|jj}z|j}Wn ty$|j}Ynw|j} |dd} z-tj ||| d|_||i|} | rV| ddrV| dd d d  d} | W| |_S| |_w) 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_contentTlatin1unicode_escape) items__self__ api_client configurationAttributeErrorconfigrequestpop functoolspartialgetencodedecode) websocket_request force_kwargs api_methodargskwargskwargvaluer r prev_requestroutr Z/home/air/sanwanet/backup_V2/venv/lib/python3.10/site-packages/kubernetes/stream/stream.py_websocket_requests$     r"rF) rrr"rwebsocket_callstreamportforward_call portforwardr r r r!s