persistence/com.wire.kalium.persistence.dao.conversation/ConversationListPagingSource

ConversationListPagingSource

internal class ConversationListPagingSource(queries: ConversationListQueries, query: ConversationListQueryEntity, readDispatcher: ReadDispatcher) : PagingSource<ConversationListPositionEntity, ConversationListItemEntity> , Query.Listener

Constructors

ConversationListPagingSource

constructor(queries: ConversationListQueries, query: ConversationListQueryEntity, readDispatcher: ReadDispatcher)

Properties

val invalid: Boolean

invalidateCallbackCount

@get:VisibleForTesting

internal val invalidateCallbackCount: Int

jumpingSupported

open val jumpingSupported: Boolean

keyReuseSupported

open val keyReuseSupported: Boolean

Functions

open override fun getRefreshKey(state: PagingState<ConversationListPositionEntity, ConversationListItemEntity>): ConversationListPositionEntity?

fun invalidate()

open suspend override fun load(params: PagingSource.LoadParams<ConversationListPositionEntity>): PagingSource.LoadResult<ConversationListPositionEntity, ConversationListItemEntity>

queryResultsChanged

open override fun queryResultsChanged()

registerInvalidatedCallback

fun registerInvalidatedCallback(onInvalidatedCallback: () -> Unit)

unregisterInvalidatedCallback

fun unregisterInvalidatedCallback(onInvalidatedCallback: () -> Unit)