RxJava 好难理解的一个 FlatMap 的例子

需求是获取系统所有的文件，代码如下：

  File file = new File(Environment.getExternalStorageDirectory().getPath());
  //定义一个被观察者
  Observable<File> observable = Observable.just(file)
                .flatMap(new Function<File, ObservableSource<File>>() {
                    @Override
                    public ObservableSource<File> apply(@NonNull File file) throws Exception {
                        return listFile(file);
                    }
                });
  //定义一个观察者
  Observer<File> observer = new Observer<File>() {
            @Override
            public void onSubscribe(Disposable d) {

            }

            @Override
            public void onNext(File file) {
            }

            @Override
            public void onError(Throwable e) {

            }

            @Override
            public void onComplete() {

            }
        };
  //订阅
  observable.subscribe(observer);
 }
  //递归文件,
  private Observable<File> listFile(File file) {
        if (file.isDirectory()) {
            Observable<File> ob = Observable.fromArray(file.listFiles())
                    .flatMap(new Function<File, ObservableSource<File>>() {
                        @Override
                        public ObservableSource<File> apply(@NonNull File file) throws Exception {
                            return listFile(file);
                        }
                    });
            return ob;
        } else {
            return Observable.just(file);
        }
}

平时使用FlatMap的例子，都是集合转换为单个元素，按照“平铺”的思路，比较能理解；这里直接FlatMap结合递归，搞得人晕晕的，不知道有没有什么好理解的思路？