RxJava如何从Observable.fromCallable抛出错误（（）

Question

如果我使用：

类1：

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

等级2：

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

我怎么能扔在可观察到的错误beginUpload（）方法？

Answer 1

fromCallable需要一个Callable它有一个call() throws Exception方法，因此，你可以宣布你的方法throws X其中X是你需要抛出异常类型：

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