当 RxJava 发生错误时做一个动作

Question

当文件夹不存在时，我需要创建一个文件夹。在我的例子中，这样做的唯一方法是捕获错误并处理它以创建所需的文件夹。但我只能找到

public static Observable<Boolean> folderExists(final Context context, final String targetPath, final String currentpath) {
    Application application = Application.get(context);
//i browse the folder to get all the items
        return browseFolderObservable(context,currentpath)
                .subscribeOn(application.defaultSubscribeScheduler())
                .doOnError(new Action1<Throwable>() {
                    @Override
                    public void call(Throwable throwable) {
                        BsSdkLog.d("Error no file found");
                    }
            })

            .map(new Func1<ArrayList<Item>, Boolean>() {
                @Override
                public Boolean call(ArrayList<Item> items) {

                    if(items.isEmpty()) {

                        BsSdkLog.d(" No items");
                        return false;
                    }else  {
                        for(int i=0;i<items.size();i++)
                        {
                            Item item=items.get(i);
                            BsSdkLog.d(item.toString());
                        }
                        BsSdkLog.d("Right-here");
                        return true;

                    }
                }
            });


}

我想在发生错误时调用创建文件夹的方法，但我不知道该怎么做。我是新手，所以非常感谢您的帮助谢谢

Answer 1

基本原理如下所示。我使用 Java NIO 库进行测试。

方法'createFolder'只是创建一个文件夹。测试 'name' 调用 Single 并检查异常。如果它是一个 IOException 它将 return 一个回退值。你可以在那里做一些不同的事情。您只需提供后备单。如果它是一个不同于 IOException 的错误，它将 return 错误。

@Test
void name() throws Exception {
    final String TO_CREATE = "/home/sergej/Downloads/Wurstbrot";
    this.createFolder(TO_CREATE)
            .onErrorResumeNext(throwable -> { // handle Exception:
                // Validate Exception
                if (throwable instanceof IOException) {
                    // Return fallback
                    return Single.just(Paths.get("/home/sergej/Downloads/"));
                }

                return Single.error(throwable);

            })
            .test()
            .await()
            .assertValueCount(1)
            .assertValue(path -> path.endsWith(TO_CREATE))
            .assertNoErrors();

}

private Single<Path> createFolder(String p) {
    return Single.defer(() -> { // may throw some IOException

        Path path = Paths.get(p);

        if (!Files.exists(path)) {
            Path createdDirectory = Files.createDirectory(path); // will throw if already exists

            return Single.just(createdDirectory);
        }

        // Or just return Path, because it already exists???
        return Single.error(new IOException("Already exists"));
    });
}

当 RxJava 发生错误时做一个动作

Do an action when an error occurs RxJava

error-handling

rx-java

rx-android