fix: asyncio.async() removed in py3.7, use ensure_future

nicfit · Apr 2, 2018 · 5bb5c99 · 5bb5c99
1 parent 7afbd03
commit 5bb5c99
Showing 1 changed file with 2 additions and 3 deletions.
diff --git a/vexmpp/ssl_transport.py b/vexmpp/ssl_transport.py
@@ -207,9 +207,7 @@ def _force_close(self, exc):
         self._trace_logger.debug("_force_close called")
         self._remove_rw()
         if self._state == _State.CLOSED:
-            # don’t raise here
             raise self._invalid_state("_force_close called")
-            return
 
         self._state = _State.CLOSED
 
@@ -314,7 +312,8 @@ def _tls_do_handshake(self):
 
         if self._tls_post_handshake_callback:
             self._trace_logger.debug("post handshake scheduled via callback")
-            task = asyncio.async(self._tls_post_handshake_callback(self))
+            task = asyncio.ensure_future(
+                self._tls_post_handshake_callback(self))
             task.add_done_callback(self._tls_post_handshake_done)
             self._tls_post_handshake_callback = None
         else: