Background

I’m trying to make the repository and use cases return a Flow.

Since I’m using a paging source, I need to consume my Flow before being able to use it within the suspend fun load(params: LoadParams): LoadResult<Key, Value> async method.

The RxJava approach is: Observable.toSingle, which I expect to be Flow.first().

Issue

However, it returns a NoSuchElementException.

Any help would be appreciated.