and upstream is like this

lifeCycle.inForegroundObservable
    .switchMap {
       if(it) cameraHelper.start() else Observable.empty
    }