RxJava Comment lancer une erreur de Observable.fromCallable (()

Question

Si j'utilise:

classe 1:

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

class2:

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

comment puis-je jeter une erreur dans Observable la méthode beginUpload()?

Answer 1

fromCallable prend un Callable qui a un call() throws Exception méthode, par conséquent, vous pouvez déclarer votre méthode comme throws X où X est le type d'exception que vous devez jeter:

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