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

AsyncQueryPagingSource

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)