Извлечение данных через flatMap не вызывает подписку - PullRequest
Новая
       30

Извлечение данных через flatMap не вызывает подписку

0 голосов
/ 03 октября 2018

Я пытаюсь извлечь информацию из наблюдаемого с помощью flatMap, но после этого он не будет вызывать подписку.Когда я возвращаю Observable.just(it) из flatMap, подписка вызывается, как и ожидалось, но тогда я не могу получить информацию. 

conn.setupNotification(UUID_GATT_DFU_DEVICE_FIRMWARE_UPDATE_STATUS, NotificationSetupMode.COMPAT)
                .subscribeOn(Schedulers.newThread())
                .doOnNext{
                    Timber.d("this is called")
                }
                .flatMap {
                    Timber.d("this is called")
                    //Observable.just(it) with this subscribe is called
                    it
                }
                .observeOn(AndroidSchedulers.mainThread())
                .subscribe(
                    { status ->
                        Timber.d("NOTIFY RESPONSE STATUS: @@@ $status")
                    },
                    {
                        Timber.d(it)
                    },
                    {
                        Timber.d("ON COMPLETE notify observer")
                    }
                ).also {
                    notificationDisposable.add(it)
                }

что я делаю неправильно?Мне нужно извлечь наблюдаемое, но как, когда flatMap не работает, как ожидалось?Я также пробовал другую подписку в методе onNext, но он также не работал.

...