CoHostStore

void addCoHostListener(CoHostListener listener);

void removeCoHostListener(CoHostListener listener);

Future<CompletionHandler> requestHostConnection({
    required String targetHostLiveID,
    required CoHostLayoutTemplate layoutTemplate,
    required int timeout,
    String extraInfo = '',
});

Future<CompletionHandler> cancelHostConnection(String toHostLiveID);

Future<CompletionHandler> acceptHostConnection(String fromHostLiveID);

Future<CompletionHandler> rejectHostConnection(String fromHostLiveID);

Future<CompletionHandler> exitHostConnection();

Future<CompletionHandler> getCoHostCandidates(String cursor);

// 创建 store 实例
final store = CoHostStore.create('live_room_123');

// 定义监听器
late final VoidCallback statusListener = _onStatusChanged;
late final VoidCallback connectedListener = _onConnectedChanged;

void _onStatusChanged() {
    print('连线状态: ${store.coHostState.coHostStatus.value}');
}

void _onConnectedChanged() {
    print('已连接主播: ${store.coHostState.connected.value.length}');
}

// 订阅状态变化
store.coHostState.coHostStatus.addListener(statusListener);
store.coHostState.connected.addListener(connectedListener);

// 添加连线事件监听器
final coHostListener = CoHostListener(
    onCoHostRequestReceived: (inviter, extensionInfo) {
        print('收到来自 ${inviter.userName} 的连线请求');
        // 显示接受/拒绝的 UI
    },
    onCoHostRequestAccepted: (invitee) {
        print('连线请求被 ${invitee.userName} 接受');
    },
    onCoHostUserJoined: (userInfo) {
        print('主播 ${userInfo.userName} 加入连线');
    },
);
store.addCoHostListener(coHostListener);

// 发起连线请求
final result = await store.requestHostConnection(
    targetHostLiveID: 'target_live_id',
    layoutTemplate: CoHostLayoutTemplate.hostDynamicGrid,
    timeout: 30,
    extraInfo: '',
);
if (result.code == 0) {
    print('连线请求发送成功');
}

// 完成后取消订阅
store.coHostState.coHostStatus.removeListener(statusListener);
store.coHostState.connected.removeListener(connectedListener);
store.removeCoHostListener(coHostListener);