我正在尝试将此 RxJava1 代码转换为 RxJava2
public static Observable<Path> listFolder(Path dir, String glob) {
return Observable.<Path>create(subscriber -> {
try {
DirectoryStream<Path> stream =
Files.newDirectoryStream(dir, glob);
subscriber.add(Subscriptions.create(() -> {
try {
stream.close();
} catch (IOException e) {
e.printStackTrace();
}
}));
Observable.<Path>from(stream).subscribe(subscriber);
} catch (DirectoryIteratorException ex) {
subscriber.onError(ex);
} catch (IOException ioe) {
subscriber.onError(ioe);
}
});
}
问题是,在 Rxjava2 中,我没有让订阅者向它添加新订阅。
最佳答案
享受RxJava 2的简洁(Flowable
现在是背压支持类):
public static Flowable<Path> listFolder(Path dir, String glob) {
return Flowable.using(
() -> Files.newDirectoryStream(dir, glob),
stream -> Flowable.fromIterable(stream),
stream -> stream.close());
}
如果您不想背压,请将 Flowable
替换为 Observable
。
关于java - 从 RxJava 1 到 RxJava 2,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/40353058/