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(); 
}