Channel

@classmethod
async def join(
    cls,
    token: str,
    *,
    handler: ChannelHandler | None = None,
    auto_subscribe_audio: bool = False,
    auto_subscribe_video: bool = False,
    audio_format: AudioFormat = AudioFormat(),
    decode_video: bool = False,
    timeout: float = 20.0,
) -> Channel

async with await srtc.Channel.join(token, auto_subscribe_audio=True) as ch:
    ...

async def leave() -> None

async def wait_closed() -> DisconnectReason | None

reason = await ch.wait_closed()
if reason in (srtc.DisconnectReason.KICKED, srtc.DisconnectReason.REPLACE):
    return       # 被踢 / 顶号，不要自动重进

@property
def closed() -> bool

disconnect_reason: DisconnectReason | None

async def subscribe_audio(uid: str, track_id: str) -> None
async def subscribe_video(uid: str, track_id: str) -> None

async def unsubscribe(uid: str, track_id: str) -> None

def request_key_frame(uid: str, track_id: str) -> None

async def switch_layer(pub_uid: str, track_id: str, target_track_id: str) -> None

async def publish_audio(
    *,
    desc: str = "mic",
    audio_format: AudioFormat = AudioFormat(sample_rate=48000),
    bitrate: int = 32000,
    max_buffer_seconds: float = 30.0,
    props: dict | None = None,
) -> AudioTrack

async def unpublish(track: AudioTrack) -> None

async def audio_frames() -> AsyncIterator[AudioFrame]

async for frame in ch.audio_frames():
    asr.feed(frame.uid, frame.to_numpy())

async def video_frames() -> AsyncIterator[VideoFrame]