```dataRepository.dataObservable .flatMap { ...

# rx

[ursus]

dataRepository.dataObservable
    .flatMap {
        if (Looper.myLooper() == Looper.getMainLooper()) {
            Observable.just(it)
        } else {
            Observable.just(it).observeOn(schedulerProvider.main)
        }
    }
    .subscribe { ... }