``` viewModel.fooObservable() .fla...

# rx

[ursus]

viewModel.fooObservable()
                .flatMap {
                    if (Looper.myLooper() == Looper.getMainLooper()) {
                        Observable.just(it)
                    } else {
                        Observable.just(it)
                                .observeOn(AndroidSchedulers.mainThread())
                    }
                }
                .subscribe {
                    adapter.setItems(it)
                }