We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
2 parents aadf352 + 975e22a commit 410880dCopy full SHA for 410880d
1 file changed
rethinkdb/asyncio_net/net_asyncio.py
@@ -274,6 +274,7 @@ async def close(self, noreply_wait=False, token=None, exception=None):
274
await self.run_query(noreply, False)
275
276
self._streamwriter.close()
277
+ await self._streamwriter.wait_closed()
278
# We must not wait for the _reader_task if we got an exception, because that
279
# means that we were called from it. Waiting would lead to a deadlock.
280
if self._reader_task and exception is None:
0 commit comments