直播列表（Android）


import android.os.Bundle
import android.util.Log
import androidx.appcompat.app.AppCompatActivity
import com.trtc.uikit.livekit.livelist.LiveListView
import io.trtc.tuikit.atomicxcore.api.CompletionHandler
import io.trtc.tuikit.atomicxcore.api.live.LiveListStore

class AudienceLiveListActivity : AppCompatActivity() {

    companion object {
        private const val TAG = "AudienceLiveListActivity"
        private const val FETCH_COUNT = 6
        const val EXTRA_LIVE_ID = "liveID"
    }

    private lateinit var liveListView: LiveListView

    private var isLoading = false

    override fun onCreate(savedInstanceState: Bundle?) {
        super.onCreate(savedInstanceState)
        val liveID = intent.getStringExtra(EXTRA_LIVE_ID).orEmpty()

        // 1. 创建 LiveListView，构造时传入的 liveID 会作为首屏直播间
        //    重写 onLoadMore，在观众滑动到列表末尾前加载更多数据
        liveListView = object : LiveListView(this, liveID = liveID) {
            override fun onLoadMore() {
                loadMore()
            }
        }

        // 2. 将 LiveListView 添加到界面
        setContentView(liveListView)

        // 3. 拉取首屏直播间列表并设置给 LiveListView
        refresh()
    }

    private fun refresh() {
        if (isLoading) return
        fetch(isRefresh = true, callback = object : CompletionHandler {
            override fun onSuccess() {
                liveListView.setData(LiveListStore.shared().liveState.liveList.value)
                isLoading = false
            }

            override fun onFailure(code: Int, desc: String) {
                Log.e(TAG, "refresh failed, code:$code, desc:$desc")
                isLoading = false
            }
        })
    }

    private fun loadMore() {
        if (isLoading) return
        val cursor = LiveListStore.shared().liveState.liveListCursor.value
        if (cursor.isEmpty()) return

        val oldSize = LiveListStore.shared().liveState.liveList.value.size
        fetch(isRefresh = false, callback = object : CompletionHandler {
            override fun onSuccess() {
                val newList = LiveListStore.shared().liveState.liveList.value
                if (newList.size > oldSize) {
                    liveListView.appendData(newList.subList(oldSize, newList.size))
                }
                isLoading = false
            }

            override fun onFailure(code: Int, desc: String) {
                Log.e(TAG, "loadMore failed, code:$code, desc:$desc")
                isLoading = false
            }
        })
    }

    private fun fetch(isRefresh: Boolean, callback: CompletionHandler) {
        isLoading = true
        val cursor = LiveListStore.shared().liveState.liveListCursor.value
        val fetchCursor = if (isRefresh || cursor.isEmpty()) "" else cursor
        LiveListStore.shared().fetchLiveList(fetchCursor, FETCH_COUNT, object : CompletionHandler {
            override fun onSuccess() {
                callback.onSuccess()
            }

            override fun onFailure(code: Int, desc: String) {
                callback.onFailure(code, desc)
            }
        })
    }
}


// 跳转到「滑动切换直播间」观看页
fun enterLiveListPage(context: Context, liveID: String) {
    val intent = Intent(context, AudienceLiveListActivity::class.java)
    intent.putExtra(AudienceLiveListActivity.EXTRA_LIVE_ID, liveID)
    context.startActivity(intent)
}