diff --git a/src/main/java/it/tdlight/tdlibsession/td/easy/AsyncTdEasy.java b/src/main/java/it/tdlight/tdlibsession/td/easy/AsyncTdEasy.java index fe9fca4..7691fc0 100644 --- a/src/main/java/it/tdlight/tdlibsession/td/easy/AsyncTdEasy.java +++ b/src/main/java/it/tdlight/tdlibsession/td/easy/AsyncTdEasy.java @@ -562,6 +562,9 @@ public class AsyncTdEasy { sessionPath.resolve("thumbnails"), sessionPath.resolve("wallpapers") )) + .filterWhen(file -> Mono + .fromCallable(() -> Files.exists(file)) + .subscribeOn(Schedulers.boundedElastic())) .doOnNext(directory -> { try { if (!Files.walk(directory)