From a2e89d2acd4a4b5584b3169a9a7eb79c254bfdfb Mon Sep 17 00:00:00 2001 From: Andrea Cavalli Date: Sat, 18 Sep 2021 01:05:47 +0200 Subject: [PATCH] Remove doOnError --- src/main/java/org/warp/filesponge/FileSpongeUtils.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/src/main/java/org/warp/filesponge/FileSpongeUtils.java b/src/main/java/org/warp/filesponge/FileSpongeUtils.java index 795ab4d..9cb1a60 100644 --- a/src/main/java/org/warp/filesponge/FileSpongeUtils.java +++ b/src/main/java/org/warp/filesponge/FileSpongeUtils.java @@ -37,11 +37,11 @@ public class FileSpongeUtils { private static final Logger logger = LoggerFactory.getLogger(FileSponge.class); public static Mono firstWithValueMono(List> monos) { - return Mono.firstWithValue(monos).doOnError(ex -> {}).onErrorResume(FileSpongeUtils::ignoreFakeErrors); + return Mono.firstWithValue(monos).onErrorResume(FileSpongeUtils::ignoreFakeErrors); } public static Flux firstWithValueFlux(List> monos) { - return Flux.firstWithValue(monos).doOnError(ex -> {}).onErrorResume(FileSpongeUtils::ignoreFakeErrors); + return Flux.firstWithValue(monos).onErrorResume(FileSpongeUtils::ignoreFakeErrors); } private static Mono ignoreFakeErrors(Throwable ex) {