Don't delete missing files
This commit is contained in:
parent
ec43b167bf
commit
075bf5ad40
@ -562,6 +562,9 @@ public class AsyncTdEasy {
|
|||||||
sessionPath.resolve("thumbnails"),
|
sessionPath.resolve("thumbnails"),
|
||||||
sessionPath.resolve("wallpapers")
|
sessionPath.resolve("wallpapers")
|
||||||
))
|
))
|
||||||
|
.filterWhen(file -> Mono
|
||||||
|
.fromCallable(() -> Files.exists(file))
|
||||||
|
.subscribeOn(Schedulers.boundedElastic()))
|
||||||
.doOnNext(directory -> {
|
.doOnNext(directory -> {
|
||||||
try {
|
try {
|
||||||
if (!Files.walk(directory)
|
if (!Files.walk(directory)
|
||||||
|
Loading…
Reference in New Issue
Block a user