Skip to content

Commit 410880d

Browse files
authored
Merge pull request #267 from dpineiden/patch-1
Update net_asyncio.py
2 parents aadf352 + 975e22a commit 410880d

File tree

1 file changed

+1
-0
lines changed

1 file changed

+1
-0
lines changed

rethinkdb/asyncio_net/net_asyncio.py

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -274,6 +274,7 @@ async def close(self, noreply_wait=False, token=None, exception=None):
274274
await self.run_query(noreply, False)
275275

276276
self._streamwriter.close()
277+
await self._streamwriter.wait_closed()
277278
# We must not wait for the _reader_task if we got an exception, because that
278279
# means that we were called from it. Waiting would lead to a deadlock.
279280
if self._reader_task and exception is None:

0 commit comments

Comments
 (0)