logic/com.wire.kalium.logic.data.message.timeline/MessageTimelinePagingSource

MessageTimelinePagingSource

internal class MessageTimelinePagingSource(dao: MessageTimelineDAO, selfUserId: UserId, conversationId: ConversationId, policy: MessageTimelinePolicy, initialRequest: MessageTimelineRequest) : PagingSource<MessageTimelineCursor, MessageListItem>

Constructors

MessageTimelinePagingSource

constructor(dao: MessageTimelineDAO, selfUserId: UserId, conversationId: ConversationId, policy: MessageTimelinePolicy, initialRequest: MessageTimelineRequest)

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<MessageTimelineCursor, MessageListItem>): MessageTimelineCursor?

fun invalidate()

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

registerInvalidatedCallback

fun registerInvalidatedCallback(onInvalidatedCallback: () -> Unit)

unregisterInvalidatedCallback

fun unregisterInvalidatedCallback(onInvalidatedCallback: () -> Unit)