Как повторить поток RxJava2 снова? - PullRequest
Новая
       3

Как повторить поток RxJava2 снова?

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

Вот как выглядит мой поток: 

cameraStateObservable
            .switchMap(cameraStateEvent -> {
                if (cameraStateEvent.eventType.equals(CameraStateEvent.EventType.DISCONNECTED)) {
                    return cameraAvailabilityObservable
                             .filter(aBoolean -> aBoolean)
                             .START AGAIN 
                } else if(...){
                         .....
                       }
            })
            .subscribe();

cameraStateObservable выдает текущее состояние устройства камеры.Когда он отключается, cameraAvailabilityObservable начинает выдавать логические значения, указывающие, готово ли устройство камеры к повторному использованию или нет.Когда он будет готов, мне нужно начать поток заново с самого начала.Как я могу справиться с этой ситуацией?

...