persistence/com.wire.kalium.persistence.dao.message/AsyncQueryPagingSource

AsyncQueryPagingSource

internal class AsyncQueryPagingSource<RowType : Any>(countQuery: <Error class: unknown class><Long>, context: <Error class: unknown class>, queryProvider: (limit: Long, offset: Long) -> <Error class: unknown class><RowType>, initialOffset: Long = 0, postProcessor: suspend (List<RowType>) -> List<RowType>? = null)

Constructors

constructor(countQuery: <Error class: unknown class><Long>, context: <Error class: unknown class>, queryProvider: (limit: Long, offset: Long) -> <Error class: unknown class><RowType>, initialOffset: Long = 0, postProcessor: suspend (List<RowType>) -> List<RowType>? = null)

Properties

jumpingSupported

open val jumpingSupported: Boolean

Functions

getRefreshKey

open fun getRefreshKey(state: <Error class: unknown class><Int, RowType>): Int?

load

open suspend fun load(params: <Error class: unknown class><Int>): <Error class: unknown class><Int, RowType>

queryResultsChanged

open fun queryResultsChanged(): <Error class: unknown class>