stream.map(someThrowableFunc).catchError().subscribe() // これだとエラーが流れた時点でおしまい stream.flatMap { Observable.from(someThrowableFunc($0)).catchError() // Errorでdisposeになるのはこのsubscription }.subscribe() // 従ってこちらには影響しない
