small client fixes

Author: miguelgrinberg

socketio/__init__.py

@@ -11,14 +11,14 @@
 from .middleware import WSGIApp, Middleware
 from .tornado import get_tornado_handler
 if sys.version_info >= (3, 5):  # pragma: no cover
-    # from .asyncio_client import AsyncClient
     from .asyncio_client import AsyncClient
     from .asyncio_server import AsyncServer
     from .asyncio_manager import AsyncManager
     from .asyncio_namespace import AsyncNamespace, AsyncClientNamespace
     from .asyncio_redis_manager import AsyncRedisManager
     from .asgi import ASGIApp
 else:  # pragma: no cover
+    AsyncClient = None
     AsyncServer = None
     AsyncManager = None
     AsyncNamespace = None

socketio/asyncio_client.py

@@ -13,9 +13,9 @@
 
 
 class AsyncClient(client.Client):
-    """An Socket.IO client for asyncio.
+    """A Socket.IO client for asyncio.
 
-    This class implements a fully compliant Engine.IO web client with support
+    This class implements a fully compliant Socket.IO web client with support
     for websocket and long-polling transports.
 
     :param reconnection: ``True`` if the client should automatically attempt to
@@ -110,6 +110,7 @@ async def wait(self):
         """
         while True:
             await self.eio.wait()
+            await self.sleep(1)  # give the reconnect task time to start up
             if not self._reconnect_task:
                 break
             await self._reconnect_task

socketio/client.py

@@ -13,9 +13,9 @@
 
 
 class Client(object):
-    """An Socket.IO client.
+    """A Socket.IO client.
 
-    This class implements a fully compliant Engine.IO web client with support
+    This class implements a fully compliant Socket.IO web client with support
     for websocket and long-polling transports.
 
     :param reconnection: ``True`` if the client should automatically attempt to
@@ -214,6 +214,7 @@ def wait(self):
         """
         while True:
             self.eio.wait()
+            self.sleep(1)  # give the reconnect task time to start up
             if not self._reconnect_task:
                 break
             self._reconnect_task.join()