快速开始

final engine = await RtcEngine.create(
  signaling: WhipWhepSignaling(
    whipUrl: 'https://srs.example.com/rtc/v1/whip/',
    whepUrl: 'https://srs.example.com/rtc/v1/whep/',
    // 跨公网必须部署 TURN。
    iceServers: <IceServer>[
      const IceServer(urls: 'stun:stun.example.com:3478'),
      IceServer(
        urls: 'turn:turn-ap.example.com:3478',
        username: await token.turnUser(),
        credential: await token.turnPass(),
      ),
    ],
  ),
);

final session = await engine.join(
  roomId: 'robot-42',
  role: RtcRole.robotOperator,
);
 
final remote = await session.subscribe(
  streamId: 'robot-42',
  quality: ClarityLevel.p720,
);
 
// 渲染
RtcVideoView(subscriber: remote);

final publisher = session.localPublisher!;
await publisher.startCamera(
  facing: CameraFacing.rear,
  maxClarity: ClarityLevel.p720,
);
await publisher.startMic();
 
// 只限制 simulcast 最高层，不影响会话。
await publisher.setPublishClarity(ClarityLevel.p360);

session.events.listen((event) {
  switch (event) {
    case RtcConnectionStateChanged():
      debugPrint('状态 ${event.state}');
    case RtcError():
      debugPrint('错误 ${event.error.code}');
    case RtcDisconnected():
      debugPrint('断开：${event.reason}');
    default:
      break;
  }
});

final resilient = await ResilientSession.connect(
  roomId: 'robot-42',
  role: RtcRole.robotOperator,
  factory: engine.join,
  config: ResilientSessionConfig(
    relay: RelayPlanner(servers: iceServers),
    monitor: CallbackNetworkMonitor(),
  ),
);

await resilient.dispose(); // 或 await session.leave();
await engine.dispose();