o \h ã@sDddlZddlmZdd„Ze eejd¡Ze eejddi¡ZdS)éNé)Ú ws_clientc OsÀ|r| ¡D]\}}|||<q|jj}z|j}Wn ty$|j}Ynw|j} | dd¡} z-tj ||| d|_||i|¤Ž} | rV|  dd¡rV| dd…  d¡  d ¡  d¡} | W| |_S| |_w) z”Override 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Úout©r ú[/home/air/segue/gemini/backup/venv/lib/python3.10/site-packages/kubernetes/stream/stream.pyÚ_websocket_requests$    ÿ r"rF) rÚrr"rÚwebsocket_callÚstreamÚportforward_callÚ portforwardr r r r!Ús