33 lines
1.1 KiB
Kotlin
33 lines
1.1 KiB
Kotlin
package org.pixeldroid.app.posts.feeds.uncachedFeeds.comments
|
|
|
|
import androidx.paging.ExperimentalPagingApi
|
|
import androidx.paging.Pager
|
|
import androidx.paging.PagingConfig
|
|
import androidx.paging.PagingData
|
|
import kotlinx.coroutines.flow.Flow
|
|
import org.pixeldroid.app.posts.feeds.uncachedFeeds.UncachedContentRepository
|
|
import org.pixeldroid.app.posts.feeds.uncachedFeeds.profile.ProfilePagingSource
|
|
import org.pixeldroid.app.utils.api.PixelfedAPI
|
|
import org.pixeldroid.app.utils.api.objects.Status
|
|
import javax.inject.Inject
|
|
|
|
class CommentContentRepository @ExperimentalPagingApi
|
|
@Inject constructor(
|
|
private val api: PixelfedAPI,
|
|
private val statusId: String
|
|
) : UncachedContentRepository<Status> {
|
|
override fun getStream(): Flow<PagingData<Status>> {
|
|
return Pager(
|
|
config = PagingConfig(
|
|
initialLoadSize = NETWORK_PAGE_SIZE,
|
|
pageSize = NETWORK_PAGE_SIZE),
|
|
pagingSourceFactory = {
|
|
CommentPagingSource(api, statusId)
|
|
}
|
|
).flow
|
|
}
|
|
|
|
companion object {
|
|
private const val NETWORK_PAGE_SIZE = 20
|
|
}
|
|
} |