fun onEpisodeItemClicked(view: View, episode: Episode) {    // 通知 InboxRecyclerView 展开剧集项    // 向其传入需要展开的项目的 id    recyclerView.expandItem(episode.id)}

fun onNextEpisodeToWatchItemClick(view: View, nextEpisodeToWatch: Episode) {    // 通知 ViewModel 使 RecyclerView 的数据集中包含对应季份的剧集。    // 这个操作会触发数据拉取，并且会更新视图状态    viewModel.expandSeason(nextEpisodeToWatch.seasonId)
    // 滑动 RecyclerView 展示指定的剧集    recyclerView.scrollToItemId(nextEpisodeToWatch.id)
    // 使用之前的方法展开该条目    recyclerView.expandItem(nextEpisodeToWatch.id)}

fun onNextEpisodeToWatchItemClick(view: View, nextEpisodeToWatch: Episode) {    // 通知在 RecycleView 数据集中包含该集所在季份列表的 ViewModel,并触发数据的更新    viewModel.expandSeason(nextEpisodeToWatch.seasonId)
    // TODO 等待 ViewModel 分发新的状态    // TODO 等待 RecyclerView 的适配器对比新的数据集    // TODO 等待 RecyclerView 将新条目布局
    // 滑动 RecyclerView 展示指定的剧集    recyclerView.scrollToItemId(nextEpisodeToWatch.id)
    // TODO 等待 RecyclerView 滑动结束
    // 使用之前的方法展开该条目    recyclerView.expandItem(nextEpisodeToWatch.id)}

fun expandEpisodeItem(itemId: Long) {    recyclerView.expandItem(itemId)}
fun scrollToEpisodeItem(position: Int) {   recyclerView.smoothScrollToPosition(position)
   // 增加一个滑动监听器，等待 RV 滑动停止   recyclerView.addOnScrollListener(object : OnScrollListener() {        override fun onScrollStateChanged(recyclerView: RecyclerView, newState: Int) {            if (newState == RecyclerView.SCROLL_STATE_IDLE) {                expandEpisodeItem(episode.id)            }        }    })}
fun waitForEpisodeItemInAdapter() {    // 我们需要等待适配器包含指定条目的id    val position = adapter.findItemIdPosition(itemId)    if (position != RecyclerView.NO_POSITION) {        // 目标项已经在适配器中了，我们可以滑动到该 id 的条目处        scrollToEpisodeItem(itemId))    } else {       // 否则我们等待新的条目添加到适配器中，然后在重试       adapter.registerAdapterDataObserver(object : AdapterDataObserver() {            override fun onItemRangeInserted(positionStart: Int, itemCount: Int) {                waitForEpisodeItemInAdapter()            }        })    }}
// 通知 ViewModel 展开指定的季份数据viewModel.expandSeason(nextEpisodeToWatch.seasonId)// 我们等待新的数据waitForEpisodeItemInAdapter()

viewLifecycleOwner.lifecycleScope.launch {        // 等待适配器中已经包含指定剧集的 ID    adapter.awaitItemIdExists(episode.id)    // 找到指定季份的条目位置    val seasonItemPosition = adapter.findItemIdPosition(episode.seasonId)
    // 滑动 RecyclerView 使该季份的条目显示在其区域的最上方    recyclerView.smoothScrollToPosition(seasonItemPosition)    // 等待滑动结束    recyclerView.awaitScrollEnd()
    // 最后，展开该集的条目，并展示详细内容    recyclerView.expandItem(episode.id)}

/** * 等待过渡动画结束，目的是让指定 [transitionId] 的动画执行完成 *  * @param transitionId 需要等待执行完成的过渡动画集 * @param timeout 过渡动画执行的超时时间，默认 5s */suspend fun MultiListenerMotionLayout.awaitTransitionComplete(transitionId: Int, timeout: Long = 5000L) {    // 如果已经处于我们指定的状态，直接返回    if (currentState == transitionId) return
    var listener: MotionLayout.TransitionListener? = null
    try {        withTimeout(timeout) {            suspendCancellableCoroutine<Unit> { continuation ->                val l = object : TransitionAdapter() {                    override fun onTransitionCompleted(motionLayout: MotionLayout, currentId: Int) {                        if (currentId == transitionId) {                            removeTransitionListener(this)                            continuation.resume(Unit)                        }                    }                }                // 如果协程被取消，移除监听                continuation.invokeOnCancellation {                    removeTransitionListener(l)                }                // 最后添加监听器                addTransitionListener(l)                listener = l            }        }    } catch (tex: TimeoutCancellationException) {        // 过渡动画没有在规定的时间内完成，移除监听，并通过抛出取消异常来通知协程        listener?.let(::removeTransitionListener)        throw CancellationException("Transition to state with id: $transitionId did not" +                " complete in timeout.", tex)    }}

// 确保指定的季份列表已经展开，目标剧集已经被加载viewModel.expandSeason(nextEpisodeToWatch.seasonId)// 1.等待新的数据下发// 2.等待 RecyclerView 适配器对比新的数据集// 滑动 RecyclerView 直到指定的剧集展示出来recyclerView.scrollToItemId(nextEpisodeToWatch.id)

/** * 等待给定的[itemId]添加到了数据集中，并返回该条目在适配器中的位置 */suspend fun <VH : RecyclerView.ViewHolder> RecyclerView.Adapter<VH>.awaitItemIdExists(itemId: Long): Int {    val currentPos = findItemIdPosition(itemId)    // 如果该条目已经在数据集中了，直接返回其位置    if (currentPos >= 0) return currentPos
    // 否则，我们注册一个观察者，等待指定条目 id 被添加到数据集中。    return suspendCancellableCoroutine { continuation ->        val observer = object : RecyclerView.AdapterDataObserver() {            override fun onItemRangeInserted(positionStart: Int, itemCount: Int) {                (positionStart until positionStart + itemCount).forEach { position ->                    // 遍历新添加的条目，检查 itemId 是否匹配                    if (getItemId(position) == itemId) {                        // 移除观察者，防止协程泄漏                        unregisterAdapterDataObserver(this)                        // 恢复协程                        continuation.resume(position)                    }                }            }        }        // 如果协程被取消，移除观察者        continuation.invokeOnCancellation {            unregisterAdapterDataObserver(observer)        }        // 将观察者注册到适配器上        registerAdapterDataObserver(observer)    }}

suspend fun RecyclerView.awaitScrollEnd() {    // 平滑滚动被调用，只有在下一帧开始的时候，才真正的执行，这里进行等待第一帧    awaitAnimationFrame()    // 现在我们可以检测真实的滑动停止，如果已经停止，直接返回    if (scrollState == RecyclerView.SCROLL_STATE_IDLE) return
    suspendCancellableCoroutine<Unit> { continuation ->        continuation.invokeOnCancellation {            // 如果协程被取消，移除监听            recyclerView.removeOnScrollListener(this)            // 如果我们需要，也可以在这里停止滚动        }
        addOnScrollListener(object : RecyclerView.OnScrollListener() {            override fun onScrollStateChanged(recyclerView: RecyclerView, newState: Int) {                if (newState == RecyclerView.SCROLL_STATE_IDLE) {                    // 确保移除监听，防止协程泄漏                    recyclerView.removeOnScrollListener(this)                    // 最后，恢复协程                    continuation.resume(Unit)                }            }        })    }}

suspend fun View.awaitAnimationFrame() = suspendCancellableCoroutine<Unit> { continuation ->    val runnable = Runnable {        continuation.resume(Unit)    }    // 如果协程被取消，移除回调    continuation.invokeOnCancellation { removeCallbacks(runnable) }    // 最后发布 runnable 对象    postOnAnimation(runnable)}