intStream.flatMap{ ensurePositive($0) .catchError { エラー処理 } } .subscribe(メイン処理)

8:34 AM

こうです