Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Throw multiple exceptions as simply as possible (and sort methods) #368

Merged
merged 1 commit into from
Apr 26, 2024
Merged

Throw multiple exceptions as simply as possible (and sort methods) #368

Changes from all commits
Commits
Show all changes
1 commit
Select commit
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
111 changes: 60 additions & 51 deletions ax-java/src/main/java/com/g2forge/alexandria/java/core/error/HError.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -4,6 +4,7 @@
import java.io.IOException;
import java.io.PrintStream;
import java.util.ArrayList;
import java.util.Collection;
import java.util.Collections;
import java.util.List;
import java.util.Map;
Expand All @@ -16,8 +17,10 @@
import java.util.stream.Stream;

import com.g2forge.alexandria.java.concurrent.RuntimeInterruptedException;
import com.g2forge.alexandria.java.core.helpers.HCollection;
import com.g2forge.alexandria.java.core.helpers.HCollector.SimpleCollector;
import com.g2forge.alexandria.java.core.marker.Helpers;
import com.g2forge.alexandria.java.function.ISupplier;
import com.g2forge.alexandria.java.function.IThrowConsumer1;
import com.g2forge.alexandria.java.function.IThrowFunction1;
import com.g2forge.alexandria.java.function.IThrowRunnable;
Expand All @@ -28,6 +31,55 @@
@Helpers
@UtilityClass
public class HError {
public static <T, R, _T extends Throwable> Collector<OrThrowable<? extends T>, ?, R> collector(Supplier<_T> supplier, boolean allowPartial, Collector<? super T, ?, R> collector) {
return new SimpleCollector<OrThrowable<? extends T>, List<OrThrowable<? extends T>>, R>(ArrayList::new, List::add, (left, right) -> {
left.addAll(right);
return left;
}, list -> {
final Map<Boolean, List<OrThrowable<? extends T>>> grouped = list.stream().collect(Collectors.groupingBy(OrThrowable::isNotEmpty));
final List<OrThrowable<? extends T>> successes = grouped.get(true);
if (!(allowPartial && (successes != null) && !successes.isEmpty())) {
final List<OrThrowable<? extends T>> failures = grouped.get(false);
if ((failures != null) && !failures.isEmpty()) HError.throwQuietly(HError.createWithSuppressed(supplier, failures.stream().map(OrThrowable::getThrowable).collect(Collectors.toList())));
}
return ((successes == null) ? Stream.<T>empty() : successes.stream().map(OrThrowable::get)).collect(collector);
}, Collections.emptySet());
}

public static <T extends Throwable> Collector<Throwable, ?, Void> collector(Supplier<T> supplier, boolean allowPartial) {
return new SimpleCollector<Throwable, List<Throwable>, Void>(ArrayList::new, List::add, (left, right) -> {
left.addAll(right);
return left;
}, list -> {
if (allowPartial && list.contains(null)) return null;
final List<Throwable> throwables = list.stream().filter(Objects::nonNull).collect(Collectors.toList());
if (!throwables.isEmpty()) HError.throwQuietly(HError.createWithSuppressed(supplier, throwables));
return null;
}, Collections.emptySet());
}

public static <T extends Throwable> T createWithSuppressed(Supplier<? extends T> supplier, Iterable<? extends Throwable> throwables) {
return withSuppressed(supplier.get(), throwables);
}

public static <T extends Throwable> T createWithSuppressed(Supplier<? extends T> supplier, Throwable... throwables) {
return withSuppressed(supplier.get(), throwables);
}

public static void throwQuietly(ISupplier<String> messageSupplier, Collection<? extends Throwable> throwables) {
if (throwables.isEmpty()) return;
if (throwables.size() == 1) throwQuietly(HCollection.getOne(throwables));
throw withSuppressed(messageSupplier == null ? new RuntimeWrappingException() : new RuntimeWrappingException(messageSupplier.get()), throwables);
}

public static void throwQuietly(Throwable throwable) {
if (throwable instanceof Error) throw (Error) throwable;
if (throwable instanceof RuntimeException) throw (RuntimeException) throwable;
if (throwable instanceof IOException) throw (RuntimeIOException) throwable;
if (throwable instanceof InterruptedException) throw (RuntimeInterruptedException) throwable;
throw new RuntimeWrappingException(throwable);
}

public static String toString(Throwable throwable) {
final ByteArrayOutputStream stream = new ByteArrayOutputStream();
throwable.printStackTrace(new PrintStream(stream));
Expand Down Expand Up @@ -80,17 +132,6 @@ public static <I> Function<I, Throwable> wrap(IThrowConsumer1<? super I, ?> cons
};
}

public static Supplier<Throwable> wrap(IThrowRunnable<?> runnable) {
return () -> {
try {
runnable.run();
} catch (Throwable throwable) {
return throwable;
}
return null;
};
}

public static <I, O> Function<I, OrThrowable<O>> wrap(IThrowFunction1<? super I, ? extends O, ?> function) {
return i -> {
try {
Expand All @@ -101,46 +142,14 @@ public static <I, O> Function<I, OrThrowable<O>> wrap(IThrowFunction1<? super I,
};
}

public static <T extends Throwable> Collector<Throwable, ?, Void> collector(Supplier<T> supplier, boolean allowPartial) {
return new SimpleCollector<Throwable, List<Throwable>, Void>(ArrayList::new, List::add, (left, right) -> {
left.addAll(right);
return left;
}, list -> {
if (allowPartial && list.contains(null)) return null;
final List<Throwable> throwables = list.stream().filter(Objects::nonNull).collect(Collectors.toList());
if (!throwables.isEmpty()) HError.throwQuietly(HError.createWithSuppressed(supplier, throwables));
return null;
}, Collections.emptySet());
}

public static <T, R, _T extends Throwable> Collector<OrThrowable<? extends T>, ?, R> collector(Supplier<_T> supplier, boolean allowPartial, Collector<? super T, ?, R> collector) {
return new SimpleCollector<OrThrowable<? extends T>, List<OrThrowable<? extends T>>, R>(ArrayList::new, List::add, (left, right) -> {
left.addAll(right);
return left;
}, list -> {
final Map<Boolean, List<OrThrowable<? extends T>>> grouped = list.stream().collect(Collectors.groupingBy(OrThrowable::isNotEmpty));
final List<OrThrowable<? extends T>> successes = grouped.get(true);
if (!(allowPartial && (successes != null) && !successes.isEmpty())) {
final List<OrThrowable<? extends T>> failures = grouped.get(false);
if ((failures != null) && !failures.isEmpty()) HError.throwQuietly(HError.createWithSuppressed(supplier, failures.stream().map(OrThrowable::getThrowable).collect(Collectors.toList())));
public static Supplier<Throwable> wrap(IThrowRunnable<?> runnable) {
return () -> {
try {
runnable.run();
} catch (Throwable throwable) {
return throwable;
}
return ((successes == null) ? Stream.<T>empty() : successes.stream().map(OrThrowable::get)).collect(collector);
}, Collections.emptySet());
}

public static <T extends Throwable> T createWithSuppressed(Supplier<? extends T> supplier, Iterable<? extends Throwable> throwables) {
return withSuppressed(supplier.get(), throwables);
}

public static <T extends Throwable> T createWithSuppressed(Supplier<? extends T> supplier, Throwable... throwables) {
return withSuppressed(supplier.get(), throwables);
}

public static void throwQuietly(Throwable throwable) {
if (throwable instanceof Error) throw (Error) throwable;
if (throwable instanceof RuntimeException) throw (RuntimeException) throwable;
if (throwable instanceof IOException) throw (RuntimeIOException) throwable;
if (throwable instanceof InterruptedException) throw (RuntimeInterruptedException) throwable;
throw new RuntimeWrappingException(throwable);
return null;
};
}
}
Loading