Close the async connection.
(self)
| 305 | return DirtyAsyncStreamIterator(self, app_path, action, args, kwargs) |
| 306 | |
| 307 | async def _close_async(self): |
| 308 | """Close the async connection.""" |
| 309 | if self._writer is not None: |
| 310 | try: |
| 311 | self._writer.close() |
| 312 | await self._writer.wait_closed() |
| 313 | except Exception: |
| 314 | pass |
| 315 | self._writer = None |
| 316 | self._reader = None |
| 317 | |
| 318 | async def close_async(self): |
| 319 | """Close the async connection.""" |
no test coverage detected