public static func create(liveID: String) -> CoHostStore {
    let store: CoHostStoreImpl = StoreFactory.shared.getStore(roomID: liveID)
    return store
}

public func requestHostConnection(targetHost liveId: String,
                                  layoutTemplate: CoHostLayoutTemplate,
                                  timeout: TimeInterval,
                                  extraInfo: String = "",
                                  completion: CompletionClosure?)
{
    fatalError("\\(#function) must be overridden by subclass")
}

public func cancelHostConnection(toHostLiveID: String, completion: CompletionClosure?) {
    fatalError("\\(#function) must be overridden by subclass")
}

public func acceptHostConnection(fromHostLiveID: String, completion: CompletionClosure?) {
    fatalError("\\(#function) must be overridden by subclass")
}

public func rejectHostConnection(fromHostLiveID: String, completion: CompletionClosure?) {
    fatalError("\\(#function) must be overridden by subclass")
}

public func exitHostConnection(completion: CompletionClosure? = nil) {
    fatalError("\\(#function) must be overridden by subclass")
}

public func muteRemoteHostAudio(liveID: String,
                                isMuted: Bool,
                                completion: CompletionClosure?)
{
    fatalError("\\(#function) must be overridden by subclass")
}

public func getCoHostCandidates(cursor: String,
                          completion: CompletionClosure?) {
    fatalError("\\(#function) must be overridden by subclass")
}

// 创建 store 实例
let store = CoHostStore.create(liveID: "live_room_123")
// 订阅状态变化
store.state.subscribe { state in
    print("连线状态: \\(state.coHostStatus)")
    print("已连接主播: \\(state.connected.count)")
}
// 订阅连线事件
store.coHostEventPublisher.sink { event in
    switch event {
    case .onCoHostRequestReceived(let inviter, let extensionInfo):
        print("收到来自 \\(inviter.userName) 的连线请求")
        // 显示接受/拒绝的 UI
    case .onCoHostRequestAccepted(let invitee):
        print("连线请求被 \\(invitee.userName) 接受")
    case .onCoHostUserJoined(let userInfo):
        print("主播 \\(userInfo.userName) 加入连线")
    default:
        break
    }
}
// 发起连线请求
store.requestHostConnection(
    targetHost: "target_live_id",
    layoutTemplate: .hostDynamicGrid,
    timeout: 30,
    extraInfo: "",
    completion: { code, message in
        if code == 0 {
            print("连线请求发送成功")
        }
    }
)