Merge pull request #18 from noahhusby/docs/examples

Do state update on connection events

aiostreammagic/stream_magic.py

@@ -89,6 +89,7 @@ async def disconnect(self):
                 await self.connect_task
             except asyncio.CancelledError:
                 pass
+            await self.do_state_update_callbacks()
 
     def is_connected(self) -> bool:
         """Return True if device is connected."""
@@ -139,6 +140,7 @@ async def connect_handler(self, res):
         self._allow_state_update = True
 
         res.set_result(True)
+        await self.do_state_update_callbacks()
         await asyncio.wait([x], return_when=asyncio.FIRST_COMPLETED)
 
     @staticmethod

examples/basic.py

@@ -19,5 +19,6 @@ async def main():
 
     await client.disconnect()
 
-if __name__ == '__main__':
+
+if __name__ == "__main__":
     asyncio.run(main())

examples/subscribe.py

@@ -13,6 +13,7 @@ async def on_state_change(client: StreamMagicClient):
     print(f"Play State: {client.get_play_state()}")
     print(f"Now Playing: {client.get_now_playing()}")
 
+
 async def main():
     """Subscribe demo entrypoint."""
     client = StreamMagicClient("192.168.20.218")
@@ -25,5 +26,5 @@ async def main():
     await client.disconnect()
 
 
-if __name__ == '__main__':
+if __name__ == "__main__":
     asyncio.run(main())

pyproject.toml

@@ -1,6 +1,6 @@
 [tool.poetry]
 name = "aiostreammagic"
-version = "2.2.3"
+version = "2.2.4"
 description = "An async python package for interfacing with Cambridge Audio / Stream Magic compatible streamers."
 authors = ["Noah Husby <32528627+noahhusby@users.noreply.github.com>"]
 maintainers = ["Noah Husby <32528627+noahhusby@users.noreply.github.com>"]