WOASDK/com.kingsoft.kim.kit.ui.chat.paging.dispatcher.abs/KBaseChatMergingDispatcher

KBaseChatMergingDispatcher

abstract class KBaseChatMergingDispatcher(val assummerId: String = "", val _state: MediatorLiveData<KBaseChatListViewModel.State>, val _draftState: LiveData<List<KChatDraft>>?, val _paginationState: MediatorLiveData<KBaseChatListViewModel.PaginationState>?, val _chatItemChangedState: MutableLiveData<KChatListItem>?) : IChatMergingDispatcher

会话合并转发相关基础功能实现

Inheritors

KChatMergingDispatcher

KInBoxChatMergingDispatcher

KInTagChatMergingDispatcher

KStickChatMergingDispatcher

Constructors

KBaseChatMergingDispatcher

constructor(assummerId: String = "", _state: MediatorLiveData<KBaseChatListViewModel.State>, _draftState: LiveData<List<KChatDraft>>?, _paginationState: MediatorLiveData<KBaseChatListViewModel.PaginationState>?, _chatItemChangedState: MutableLiveData<KChatListItem>?)

Types

object Companion

Properties

_chatItemChangedState

val _chatItemChangedState: MutableLiveData<KChatListItem>?

val _draftState: LiveData<List<KChatDraft>>?

_paginationState

val _paginationState: MediatorLiveData<KBaseChatListViewModel.PaginationState>?

val _state: MediatorLiveData<KBaseChatListViewModel.State>

val assummerId: String

open val TAG: String

Functions

cleanExtChatLoader

fun cleanExtChatLoader()

fun filterBoxList(allChats: Collection<KIMCoreChat>): MutableList<KIMCoreBox>

筛选出消息盒子

filterKIMCoreChatFromItemToMap

fun filterKIMCoreChatFromItemToMap(chats: Collection<KChatListItem>): MutableMap<String, KIMCoreChat>

筛选出BaseChatItem和BaseBoxItem两种类型的会话数据

filterTargetBoxList

fun filterTargetBoxList(allChats: Collection<KIMCoreChat>, targetBoxTypes: Set<Int>): MutableList<KIMCoreBox>

findLocalMaxChatSeq

open override fun findLocalMaxChatSeq(): Long?

查找本地最大的会话seq

getCacheExtChats

fun getCacheExtChats(): List<KExtChatItem>?

三方拓展会话

getExtChatInfoMap

fun getExtChatInfoMap(): MutableMap<KExtChatItemLoader, KChatEntryViewModel.KExtChatLoaderInfo>

fun <T> getExtra(key: String): T?

mergeComingChats

fun mergeComingChats(comingChats: List<KIMCoreChat>, currAllChatsMap: MutableMap<String, KIMCoreChat>, comingSignalTime: Pair<String, Long>, currSignalTime: Pair<String, Long>?)

根据signalTime决定数据的合并方式，用于解决新旧数据覆盖问题；

fun mergeList(chatList: List<KIMCoreChat>, boxList: List<KIMCoreBox>, extList: List<KExtChatItem>? = null): MutableList<KChatListItem>

合并KIMCoreChat、KIMCoreBox和KExtChatItem三种会话数据，创建适用于会话列表的KChatListItem

open override fun onDestroy()

资源回收操作

onDispatchChats

abstract fun onDispatchChats(pagingFrom: String, allChats: List<KIMCoreChat>, signalTime: Pair<String, Long>)

用于分发会话数据；实现此方法，可对allChats进行下一步的定制分发处理

open override fun onMergeChats(pagingFrom: String, comingChatList: List<KIMCoreChat>, countDownLatch: CountDownLatch, signalTime: Pair<String, Long>)

将comingChatList列表合并到总会话列表

onPostLoadError

open override fun onPostLoadError(pagingFrom: String, errorCode: ErrorCode)

处理加载异常

onPostPreLoadedFirstPage

open override fun onPostPreLoadedFirstPage(comingChatList: List<KIMCoreChat>, signalTime: Pair<String, Long>)

预加载的首页会话上屏处理

onPostReloadChat

open override fun onPostReloadChat(comingChat: KIMCoreChat, signalTime: Pair<String, Long>)

处理重新加载某个会话

open override fun onRemoveChat(countDownLatch: CountDownLatch, chatIdToRemove: String, signalTime: Pair<String, Long>)

从会话列表中删除会话

fun putExtra(key: String, value: Any)

fun removeExtra(key: String)

reorderChatItems

fun reorderChatItems(items: MutableList<KChatListItem>): List<KChatListItem>

重排序

setPaginationState

fun setPaginationState(reducer: KBaseChatListViewModel.PaginationState.() -> KBaseChatListViewModel.PaginationState)

分页状态更新

fun setState(reducer: KBaseChatListViewModel.State.() -> KBaseChatListViewModel.State)

fun setState(delayMs: Long, reducer: KBaseChatListViewModel.State.() -> KBaseChatListViewModel.State)

会话列表更新

shouldShowStickChat

fun shouldShowStickChat(isStickied: Boolean): Boolean

根据会话折叠功能开关，决定是否过滤掉置顶会话

fun updateChatList()

更新本地数据