flatMapSingle { result -> if(result == B } plac...
# rx
u
flatMapSingle { result -> if(result == B } placeForPrediction(result).onErrorResumeNext(Observable.empty()) else placeForPrediction(result) }