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

AsyncQueryPagingSource

internal class AsyncQueryPagingSource<RowType : Any, ItemType : Any>(countQuery: Query<Long>, context: CoroutineContext, queryProvider: (limit: Long, offset: Long) -> Query<RowType>, initialOffset: Long = 0, postProcessor: suspend (List<RowType>) -> List<ItemType>, transacter: SuspendingTransacter? = null) : PagingSource<Int, ItemType> , Query.Listener

Loads a page of query rows and optionally enriches them in one database transaction. The postprocessor must preserve row count and order so offsets remain valid.

Constructors

constructor(countQuery: Query<Long>, context: CoroutineContext, queryProvider: (limit: Long, offset: Long) -> Query<RowType>, initialOffset: Long = 0, postProcessor: suspend (List<RowType>) -> List<ItemType>, transacter: SuspendingTransacter? = null)