fix setting state in _schedule_reconnect

centrifuge/__meta__.py

@@ -1 +1 @@
-__version__ = "0.3.0b3"
+__version__ = "0.3.0b4"

centrifuge/client.py

@@ -265,7 +265,7 @@ async def _schedule_reconnect(self) -> None:
             logger.debug("won't reconnect")
             return
 
-        self.status = ClientState.CONNECTING
+        self.state = ClientState.CONNECTING
 
         delay = _backoff(
             self._reconnect_attempts,
@@ -515,7 +515,7 @@ async def _clear_connected_state(self) -> None:
         for sub in self._subs.values():
             if sub.state == SubscriptionState.SUBSCRIBED:
                 unsubscribe_code = _SubscribingCode.TRANSPORT_CLOSED
-                await sub.move_subscribing(
+                await sub._move_subscribing(
                     code=_code_number(unsubscribe_code),
                     reason=_code_message(unsubscribe_code),
                     skip_schedule_resubscribe=True,
@@ -1172,7 +1172,7 @@ async def _process_unsubscribe(self, channel: str, unsubscribe: Dict[str, Any])
             if code < 2500:
                 asyncio.ensure_future(sub._move_unsubscribed(code, unsubscribe["reason"]))
             else:
-                asyncio.ensure_future(sub.move_subscribing(code, unsubscribe["reason"]))
+                asyncio.ensure_future(sub._move_subscribing(code, unsubscribe["reason"]))
         else:
             server_sub = self._server_subs.get(channel)
             if server_sub:
@@ -1501,7 +1501,7 @@ async def _consume_subscribed_future(self) -> None:
         with contextlib.suppress(CentrifugeError):
             await self._subscribed_future
 
-    async def move_subscribing(
+    async def _move_subscribing(
         self,
         code: int,
         reason: str,