rx-java - RxJava 如何从 Observable.fromCallable(() 抛出错误

Question

如果我使用：

第一类：

Observable.fromCallable(() -> awsS3.beginUpload(data.bmpPath));

类2：

public  String beginUpload(String filePath) {
   //what if I want to throw error here?
}

如何在 beginUpload() 方法中抛出 Observable 错误？

Answer 1

fromCallable接受Callable具有call() throws Exception方法的 a，因此，您可以将方法声明为throws XX 是您需要抛出的异常类型：

public  String beginUpload(String filePath) throws IOException {
    throw new IOException();
}