@@ -357,6 +357,7 @@ async def scenario() -> None:
         )
         await asyncio.sleep(0)
         assert channel._subscription is None
+        await asyncio.gather(*tuple(client.realtime._auth_cleanup_tasks))
         assert first.calls[-1] == "disconnect"
         await channel.subscribe()
         await client.realtime.disconnect()
Original file line number	Diff line number	Diff line change
`@@ -357,6 +357,7 @@ async def scenario() -> None:`
`357`	`357`	`)`
`358`	`358`	`await asyncio.sleep(0)`
`359`	`359`	`assert channel._subscription is None`
	`360`	`+ await asyncio.gather(*tuple(client.realtime._auth_cleanup_tasks))`
`360`	`361`	`assert first.calls[-1] == "disconnect"`
`361`	`362`	`await channel.subscribe()`
`362`	`363`	`await client.realtime.disconnect()`