バックグラウンドスレッドPagingDataは、と同じように自動的に管理さPagedListれ、メインスレッドに戻されますか？

以下のログPagingDataからPagedList、ページング2のライブラリと比較して、ページング3ライブラリのバックグラウンドスレッドでは実行されていないようです。

期待する（ページングCodelabサンプルに基づく）

• override suspend fun load(...)IOスレッドで実行するGithubPagingSource。
• viewModel.searchRepo(query).collectLatest { ... }メインスレッドで実行するSearchRepositoriesActivity。

観察する

• GithubPagingSource override suspend fun load(...)とSearchRepositoriesActivityの 両方viewModel.searchRepo(query).collectLatest { ... }がメインスレッドで実行されます。

ページング2

スレッド化は、ドキュメントに従ってPagedListとtoLiveDataによってバックグラウンドで処理されます。

LivePagedListBuilderを使用してLiveDataを取得すると、バックグラウンドスレッドでPagedListsが初期化されます。

ページング3

ページング3のドキュメントには、スレッドの管理方法については記載されていません。ただし、ログから、PagingSourceメインスレッドでネットワーク要求を実行し、メインスレッドでを返しているように見えPagingDataます。

私のサンプルコード

CryptoTweetsサンプルアプリapp-simpleモジュールでCodelabパターンを再作成しました。

FeedPagingSource.kt

class FeedPagingSource : PagingSource<Int, Tweet>() {

    override suspend fun load(params: LoadParams<Int>): LoadResult<Int, Tweet> {
        try {
            val page = params.key ?: 1
            val nextPage = page + 1
            val tweets = Injection.feedService.getTweets(...)
            println("Thread: FeedPagingSource ${Thread.currentThread().name}")
            Log.v(LOG_TAG, "load success: ${tweets}")
            return LoadResult.Page(...)
        } catch (error: Exception) {
            ...
        }
    }
}

FeedRepository.kt

class FeedRepository {
    fun initFeed() = Pager(
        config = PagingConfig(pageSize = FEED_PAGEDLIST_SIZE),
        pagingSourceFactory = { FeedPagingSource() }
    ).flow
}

FeedViewModel.kt

repository.initFeed().onEach {
    println("Thread: FeedViewModel ${Thread.currentThread().name}")
    _feed.value = it
}.launchIn(viewModelScope)

試みられた解決策

PagingSourceバックグラウンドスレッドでを実行するために、フローはで開始されDispatchers.IOます。ただし、ログにはPagingSource、FeedPagingSource.ktのメインスレッドでの実行が引き続き表示されます。

FeedViewModel.kt

repository.initFeed().onEach {
            println("Thread: FeedViewModel ${Thread.currentThread().name}")
            _feed.value = it
}.flowOn(Dispatchers.IO).launchIn(viewModelScope)