TopUsersViewModel.kt

class TopUsersViewModel @Inject constructor(
    val usersRepository: UsersRepository
) : ViewModel() {
    fun getUserList(): LiveData<PagedList<User>> {
        val result = usersRepository
                .getUsers()
                .subscribeOn(Schedulers.io())
                .observeOn(AndroidSchedulers.mainThread())
                .toFlowable(BackpressureStrategy.BUFFER)
        return LiveDataReactiveStreams.fromPublisher(result)
    }

    fun dataLoadStatus(): LiveData<NetworkState> {
        val result = usersRepository.getDataLoadStatus()
                .subscribeOn(Schedulers.io())
                .observeOn(AndroidSchedulers.mainThread())
                .toFlowable(BackpressureStrategy.BUFFER)
        return LiveDataReactiveStreams.fromPublisher(result)
    }
}