public static func create(liveID: String) -> CoHostStore {
    let store: CoHostStoreImpl = StoreFactory.shared.getStore(liveId: 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 getCoHostCandidates(cursor: String,
                          completion: CompletionClosure?) {
    fatalError("\\(#function) must be overridden by subclass")
}

// Create store instance
let store = CoHostStore.create(liveID: "live_room_123")

// Subscribe to state changes
store.state.subscribe { state in
    print("Connection status: \\(state.coHostStatus)")
    print("Connected hosts: \\(state.connected.count)")
}

// Subscribe to connection events
store.coHostEventPublisher.sink { event in
    switch event {
    case .onCoHostRequestReceived(let inviter, let extensionInfo):
        print("Received connection request from \\(inviter.userName)")
        // Show accept/reject UI
    case .onCoHostRequestAccepted(let invitee):
        print("Connection request accepted by \\(invitee.userName)")
    case .onCoHostUserJoined(let userInfo):
        print("Host \\(userInfo.userName) joined connection")
    default:
        break
    }
}

// Initiate connection request
store.requestHostConnection(
    targetHost: "target_live_id",
    layoutTemplate: .hostDynamicGrid,
    timeout: 30,
    extraInfo: "",
    completion: { code, message in
        if code == 0 {
            print("Connection request sent successfully")
        }
    }
)