intStream .flatMap(ensuredPositiveIntString(i:)) .subscribe... // 👈 エラー来ても死なない func ensuredPositiveIntString(i: Int) -> Observable<Int> { if i < 0 { return Observable.error(Error.isNegative) } return Observable.just(String(i)) }
(edited)