From 4a52a71956a8d46fcb7294ac71734504bb09bcc2 Mon Sep 17 00:00:00 2001 From: S. Solomon Darnell Date: Fri, 28 Mar 2025 21:52:21 -0500 Subject: two version of R2R are here --- .../site-packages/realtime/_sync/channel.py | 30 ++++++++++++++++++++++ 1 file changed, 30 insertions(+) create mode 100644 .venv/lib/python3.12/site-packages/realtime/_sync/channel.py (limited to '.venv/lib/python3.12/site-packages/realtime/_sync/channel.py') diff --git a/.venv/lib/python3.12/site-packages/realtime/_sync/channel.py b/.venv/lib/python3.12/site-packages/realtime/_sync/channel.py new file mode 100644 index 00000000..3512f9b7 --- /dev/null +++ b/.venv/lib/python3.12/site-packages/realtime/_sync/channel.py @@ -0,0 +1,30 @@ +from __future__ import annotations + +from typing import TYPE_CHECKING, Optional + +from realtime.types import RealtimeChannelOptions + +if TYPE_CHECKING: + from .client import SyncRealtimeClient + + +class SyncRealtimeChannel: + """ + `Channel` is an abstraction for a topic listener for an existing socket connection. + Each Channel has its own topic and a list of event-callbacks that responds to messages. + Should only be instantiated through `connection.RealtimeClient().channel(topic)`. + """ + + def __init__( + self, + socket: SyncRealtimeClient, + topic: str, + params: Optional[RealtimeChannelOptions] = None, + ) -> None: + """ + Initialize the Channel object. + + :param socket: RealtimeClient object + :param topic: Topic that it subscribes to on the realtime server + :param params: Optional parameters for connection. + """ -- cgit v1.2.3