o iU @sPdZddlmZmZddlmZmZeGdddeZeGdddeZdS) uJInterface definitions for custom WebSocket transports. Implement one of these protocols to provide a custom transport to the Deepgram SDK via the ``transport_factory`` parameter:: from deepgram import DeepgramClient from deepgram.transport_interface import SyncTransport class MyTransport: """Custom transport — must satisfy SyncTransport.""" def __init__(self, url: str, headers: dict): ... # establish your connection here def send(self, data): ... # send text (str) or binary (bytes) data def recv(self): ... # return the next message (str or bytes) def __iter__(self): ... # yield messages until the connection closes def close(self): ... # tear down the connection client = DeepgramClient(api_key="...", transport_factory=MyTransport) The transport factory is the **class itself** (or any callable). The SDK calls ``factory(url, headers)`` and gets back a transport object. The SDK handles context-manager wrapping and calls ``close()`` automatically. )AnyIterator)Protocolruntime_checkablec@sHeZdZdZdeddfddZdefddZdefd d Zd d d Z dS) SyncTransportayProtocol that sync transport objects must satisfy. Methods ------- send(data) Send text (``str``) or binary (``bytes``) data over the connection. recv() Block until the next message arrives and return it. __iter__() Yield messages until the connection closes. close() Tear down the connection and release resources. datareturnNcCdSNselfrr r P/home/ubuntu/.local/lib/python3.10/site-packages/deepgram/transport_interface.pysend7zSyncTransport.sendcCr r r r r r rrecv8rzSyncTransport.recvcCr r r rr r r__iter__9rzSyncTransport.__iter__cCr r r rr r rclose:rzSyncTransport.closerN) __name__ __module__ __qualname____doc__rrrrrrr r r rr' rc@sHeZdZdZdeddfddZdefddZdefd d Zd d d ZdS)AsyncTransportasProtocol that async transport objects must satisfy. Methods ------- send(data) Send text (``str``) or binary (``bytes``) data over the connection. recv() Await the next message and return it. __aiter__() Async-yield messages until the connection closes. close() Tear down the connection and release resources. rrNcdSr r r r r rrMzAsyncTransport.sendcrr r rr r rrNrzAsyncTransport.recvcCr r r rr r r __aiter__OrzAsyncTransport.__aiter__crr r rr r rrPrzAsyncTransport.closer) rrrrrrrrrr r r rr=rrN) rtypingrrtyping_extensionsrrrrr r r rs!