将Files.walk转换为可流动的rxjava

import io.reactivex.Observable;
import io.reactivex.ObservableEmitter;
import io.reactivex.ObservableOnSubscribe;

import java.io.IOException;
import java.nio.file.Files;
import java.nio.file.Path;
import java.nio.file.Paths;

public class FilesWalkToRxJavaExample {
    public static void main(String[] args) {
        String directory = "path/to/directory";

        Observable<String> fileObservable = Observable.create(new ObservableOnSubscribe<String>() {
            @Override
            public void subscribe(ObservableEmitter<String> emitter) throws Exception {
                try {
                    Files.walk(Paths.get(directory))
                            .filter(Files::isRegularFile)
                            .forEach(path -> emitter.onNext(path.toString()));
                    emitter.onComplete();
                } catch (IOException e) {
                    emitter.onError(e);
                }
            }
        });

        fileObservable.subscribe(
                path -> System.out.println("File: " + path),
                error -> System.err.println("Error: " + error),
                () -> System.out.println("Completed")
        );
    }
}