@@ -23,9 +23,9 @@ class RESTResponse(io.IOBase):
2323 self.reason = resp.reason_phrase
2424 self.data = None
2525
26- async def read(self):
26+ { {# async} }async { {/async } } def read(self):
2727 if self.data is None:
28- self.data = await self.response.aread ()
28+ self.data = { {#async } } await { {/async } } self.response.{ {#async } }a { {/async } }read ()
2929 return self.data
3030
3131 @property
@@ -65,13 +65,13 @@ class RESTClientObject:
6565 self.proxy = configuration.proxy
6666 self.proxy_headers = configuration.proxy_headers
6767
68- self.pool_manager: Optional[httpx.AsyncClient ] = None
68+ self.pool_manager: Optional[httpx.{ {#async } }Async { {/async } }Client ] = None
6969
70- async def close(self):
70+ { {# async} }async { {/async } } def close(self):
7171 if self.pool_manager is not None:
72- await self.pool_manager.aclose ()
72+ { {#async } } await { {/async } } self.pool_manager.{ {#async } }a { {/async } }close ()
7373
74- async def request(
74+ { {# async} }async { {/async } } def request(
7575 self,
7676 method,
7777 url,
@@ -169,10 +169,10 @@ class RESTClientObject:
169169 if self.pool_manager is None:
170170 self.pool_manager = self._create_pool_manager()
171171
172- r = await self.pool_manager.request(**args)
172+ r = { {#async } } await { {/async } } self.pool_manager.request(**args)
173173 return RESTResponse(r)
174174
175- def _create_pool_manager(self) -> httpx.AsyncClient :
175+ def _create_pool_manager(self) -> httpx.{ {#async } }Async { {/async } }Client :
176176 limits = httpx.Limits(max_connections=self.maxsize)
177177
178178 proxy = None
@@ -182,7 +182,7 @@ class RESTClientObject:
182182 headers=self.proxy_headers
183183 )
184184
185- return httpx.AsyncClient (
185+ return httpx.{ {#async } }Async { {/async } }Client (
186186 limits=limits,
187187 proxy=proxy,
188188 verify=self.ssl_context,
0 commit comments