fix: Types to use Option[T]

realtime/_async/client.py

@@ -3,7 +3,7 @@
 import logging
 import re
 from functools import wraps
-from typing import Any, Callable, Dict, List, Optional, Union
+from typing import Any, Callable, Dict, List, Optional
 
 import websockets
 
@@ -243,15 +243,15 @@ def summary(self) -> None:
  for topic, channel in self.channels.items():
  print(f"Topic: {topic} | Events: {[e for e, _ in channel.listeners]}]")
 
- async def set_auth(self, token: Union[str, None]) -> None:
+ async def set_auth(self, token: Optional[str]) -> None:
  """
  Set the authentication token for the connection and update all joined channels.
 
  This method updates the access token for the current connection and sends the new token
  to all joined channels. This is useful for refreshing authentication or changing users.
 
  Args:
- token (Union[str, None]): The new authentication token. Can be None to remove authentication.
+ token (Optional[str]): The new authentication token. Can be None to remove authentication.
 
  Returns:
  None

realtime/_sync/client.py

@@ -1,4 +1,4 @@
-from typing import Any, Dict, List, Union
+from typing import Any, Dict, List, Optional
 
 from .channel import RealtimeChannelOptions, SyncRealtimeChannel
 
@@ -56,15 +56,15 @@ def remove_all_channels(self) -> None:
  """
  raise NotImplementedError(NOT_IMPLEMENTED_MESSAGE)
 
- def set_auth(self, token: Union[str, None]) -> None:
+ def set_auth(self, token: Optional[str]) -> None:
  """
  Set the authentication token for the connection and update all joined channels.
 
  This method updates the access token for the current connection and sends the new token
  to all joined channels. This is useful for refreshing authentication or changing users.
 
  Args:
- token (Union[str, None]): The new authentication token. Can be None to remove authentication.
+ token (Optional[str]): The new authentication token. Can be None to remove authentication.
 
  Returns:
  None