UsersDataSourceFactory.kt

class UsersDataSourceFactory @Inject constructor(
    val api: StackOverflowConfig
) : DataSource.Factory<Int, User>() {
    var observableEmitter: PublishSubject<UsersDataSource> = PublishSubject.create()
    override fun create(): DataSource<Int, User> {
        val usersDataSource = UsersDataSource(api)
        observableEmitter.onNext(usersDataSource)
        return usersDataSource
    }
}