From 21097c51358c3e62715b1d05a1eee362e7ee5393 Mon Sep 17 00:00:00 2001 From: Andrea Cavalli Date: Sat, 31 Jul 2021 18:01:20 +0200 Subject: [PATCH] Use flatMapIterable when possible --- src/main/java/it/tdlight/utils/BinlogUtils.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/src/main/java/it/tdlight/utils/BinlogUtils.java b/src/main/java/it/tdlight/utils/BinlogUtils.java index d9536c7..8435614 100644 --- a/src/main/java/it/tdlight/utils/BinlogUtils.java +++ b/src/main/java/it/tdlight/utils/BinlogUtils.java @@ -78,11 +78,11 @@ public class BinlogUtils { .rxReadFile(binlogPath.toString()).as(MonoUtils::toMono) .flatMap(buffer -> vertxFilesystem .rxReadDir(sessionPath.toString(), "^(?!td.binlog$).*").as(MonoUtils::toMono) - .flatMapMany(Flux::fromIterable) + .flatMapIterable(list -> list) .doOnNext(file -> logger.debug("Deleting session file {}", file)) .flatMap(file -> vertxFilesystem.rxDeleteRecursive(file, true).as(MonoUtils::toMono)) .then(vertxFilesystem.rxReadDir(mediaPath.toString(), "^(?!td.binlog$).*").as(MonoUtils::toMono)) - .flatMapMany(Flux::fromIterable) + .flatMapIterable(list -> list) .doOnNext(file -> logger.debug("Deleting media file {}", file)) .flatMap(file -> vertxFilesystem.rxDeleteRecursive(file, true).as(MonoUtils::toMono)) .onErrorResume(ex -> Mono.empty())