diff --git a/servicetalk-concurrent-api/src/main/java/io/servicetalk/concurrent/api/AbstractPubToSingle.java b/servicetalk-concurrent-api/src/main/java/io/servicetalk/concurrent/api/AbstractPubToSingle.java
index bf25095474..11239c2430 100644
--- a/servicetalk-concurrent-api/src/main/java/io/servicetalk/concurrent/api/AbstractPubToSingle.java
+++ b/servicetalk-concurrent-api/src/main/java/io/servicetalk/concurrent/api/AbstractPubToSingle.java
@@ -27,6 +27,7 @@
 import static io.servicetalk.concurrent.Cancellable.IGNORE_CANCEL;
 import static io.servicetalk.concurrent.api.SubscriberApiUtils.unwrapNullUnchecked;
 import static io.servicetalk.concurrent.internal.SubscriberUtils.checkDuplicateSubscription;
+import static io.servicetalk.utils.internal.ThrowableUtils.addSuppressed;
 
 abstract class AbstractPubToSingle<T> extends AbstractNoHandleSubscribeSingle<T> {
     private final Publisher<T> source;
@@ -110,7 +111,7 @@ void terminate(Object terminal) {
                     subscriber.onSubscribe(IGNORE_CANCEL);
                 } catch (Throwable t) {
                     if (terminal instanceof Throwable) {
-                        ((Throwable) terminal).addSuppressed(t);
+                        addSuppressed((Throwable) terminal, t);
                     } else {
                         LOGGER.warn("Unexpected exception from onSubscribe from subscriber {}. Discarding result {}.",
                                 subscriber, terminal, t);
diff --git a/servicetalk-concurrent-api/src/main/java/io/servicetalk/concurrent/api/BeforeFinallyCompletable.java b/servicetalk-concurrent-api/src/main/java/io/servicetalk/concurrent/api/BeforeFinallyCompletable.java
index f08ab5ce44..4570438cfa 100644
--- a/servicetalk-concurrent-api/src/main/java/io/servicetalk/concurrent/api/BeforeFinallyCompletable.java
+++ b/servicetalk-concurrent-api/src/main/java/io/servicetalk/concurrent/api/BeforeFinallyCompletable.java
@@ -19,6 +19,7 @@
 
 import java.util.concurrent.atomic.AtomicIntegerFieldUpdater;
 
+import static io.servicetalk.utils.internal.ThrowableUtils.addSuppressed;
 import static java.util.Objects.requireNonNull;
 
 final class BeforeFinallyCompletable extends AbstractSynchronousCompletableOperator {
@@ -78,8 +79,7 @@ public void onError(Throwable cause) {
                     doFinally.onError(cause);
                 }
             } catch (Throwable error) {
-                error.addSuppressed(cause);
-                original.onError(error);
+                original.onError(addSuppressed(error, cause));
                 return;
             }
             original.onError(cause);
diff --git a/servicetalk-concurrent-api/src/main/java/io/servicetalk/concurrent/api/BeforeFinallyPublisher.java b/servicetalk-concurrent-api/src/main/java/io/servicetalk/concurrent/api/BeforeFinallyPublisher.java
index afd403ee24..648b6b758e 100644
--- a/servicetalk-concurrent-api/src/main/java/io/servicetalk/concurrent/api/BeforeFinallyPublisher.java
+++ b/servicetalk-concurrent-api/src/main/java/io/servicetalk/concurrent/api/BeforeFinallyPublisher.java
@@ -17,6 +17,7 @@
 
 import java.util.concurrent.atomic.AtomicIntegerFieldUpdater;
 
+import static io.servicetalk.utils.internal.ThrowableUtils.addSuppressed;
 import static java.util.Objects.requireNonNull;
 
 final class BeforeFinallyPublisher<T> extends AbstractSynchronousPublisherOperator<T, T> {
@@ -93,8 +94,7 @@ public void onError(Throwable cause) {
                     doFinally.onError(cause);
                 }
             } catch (Throwable err) {
-                err.addSuppressed(cause);
-                original.onError(err);
+                original.onError(addSuppressed(err, cause));
                 return;
             }
             original.onError(cause);
diff --git a/servicetalk-concurrent-api/src/main/java/io/servicetalk/concurrent/api/BeforeFinallySingle.java b/servicetalk-concurrent-api/src/main/java/io/servicetalk/concurrent/api/BeforeFinallySingle.java
index ca9fa546d6..26392ad9df 100644
--- a/servicetalk-concurrent-api/src/main/java/io/servicetalk/concurrent/api/BeforeFinallySingle.java
+++ b/servicetalk-concurrent-api/src/main/java/io/servicetalk/concurrent/api/BeforeFinallySingle.java
@@ -19,6 +19,7 @@
 
 import java.util.concurrent.atomic.AtomicIntegerFieldUpdater;
 
+import static io.servicetalk.utils.internal.ThrowableUtils.addSuppressed;
 import static java.util.Objects.requireNonNull;
 
 final class BeforeFinallySingle<T> extends AbstractSynchronousSingleOperator<T, T> {
@@ -79,8 +80,7 @@ public void onError(Throwable cause) {
                     doFinally.onError(cause);
                 }
             } catch (Throwable err) {
-                err.addSuppressed(cause);
-                original.onError(err);
+                original.onError(addSuppressed(err, cause));
                 return;
             }
             original.onError(cause);
diff --git a/servicetalk-concurrent-api/src/main/java/io/servicetalk/concurrent/api/BeforeSubscriberCompletable.java b/servicetalk-concurrent-api/src/main/java/io/servicetalk/concurrent/api/BeforeSubscriberCompletable.java
index b12b6682ab..6ac0ec71ab 100644
--- a/servicetalk-concurrent-api/src/main/java/io/servicetalk/concurrent/api/BeforeSubscriberCompletable.java
+++ b/servicetalk-concurrent-api/src/main/java/io/servicetalk/concurrent/api/BeforeSubscriberCompletable.java
@@ -19,6 +19,7 @@
 
 import java.util.function.Supplier;
 
+import static io.servicetalk.utils.internal.ThrowableUtils.addSuppressed;
 import static java.util.Objects.requireNonNull;
 
 final class BeforeSubscriberCompletable extends AbstractSynchronousCompletableOperator {
@@ -67,8 +68,7 @@ public void onError(Throwable t) {
             try {
                 subscriber.onError(t);
             } catch (Throwable cause) {
-                t.addSuppressed(cause);
-                original.onError(t);
+                original.onError(addSuppressed(t, cause));
                 return;
             }
             original.onError(t);
diff --git a/servicetalk-concurrent-api/src/main/java/io/servicetalk/concurrent/api/BeforeSubscriberPublisher.java b/servicetalk-concurrent-api/src/main/java/io/servicetalk/concurrent/api/BeforeSubscriberPublisher.java
index c9a00d532c..f3b220bc6c 100644
--- a/servicetalk-concurrent-api/src/main/java/io/servicetalk/concurrent/api/BeforeSubscriberPublisher.java
+++ b/servicetalk-concurrent-api/src/main/java/io/servicetalk/concurrent/api/BeforeSubscriberPublisher.java
@@ -17,6 +17,7 @@
 
 import java.util.function.Supplier;
 
+import static io.servicetalk.utils.internal.ThrowableUtils.addSuppressed;
 import static java.util.Objects.requireNonNull;
 
 final class BeforeSubscriberPublisher<T> extends AbstractSynchronousPublisherOperator<T, T> {
@@ -70,8 +71,7 @@ public void onError(Throwable t) {
             try {
                 subscriber.onError(t);
             } catch (Throwable cause) {
-                t.addSuppressed(cause);
-                original.onError(t);
+                original.onError(addSuppressed(t, cause));
                 return;
             }
             original.onError(t);
diff --git a/servicetalk-concurrent-api/src/main/java/io/servicetalk/concurrent/api/BeforeSubscriberSingle.java b/servicetalk-concurrent-api/src/main/java/io/servicetalk/concurrent/api/BeforeSubscriberSingle.java
index b6cf245018..7b30fc5173 100644
--- a/servicetalk-concurrent-api/src/main/java/io/servicetalk/concurrent/api/BeforeSubscriberSingle.java
+++ b/servicetalk-concurrent-api/src/main/java/io/servicetalk/concurrent/api/BeforeSubscriberSingle.java
@@ -19,6 +19,7 @@
 
 import java.util.function.Supplier;
 
+import static io.servicetalk.utils.internal.ThrowableUtils.addSuppressed;
 import static java.util.Objects.requireNonNull;
 
 final class BeforeSubscriberSingle<T> extends AbstractSynchronousSingleOperator<T, T> {
@@ -66,8 +67,7 @@ public void onError(Throwable t) {
             try {
                 subscriber.onError(t);
             } catch (Throwable cause) {
-                t.addSuppressed(cause);
-                original.onError(t);
+                original.onError(addSuppressed(t, cause));
                 return;
             }
             original.onError(t);
diff --git a/servicetalk-concurrent-api/src/main/java/io/servicetalk/concurrent/api/CompletableMergeSubscriber.java b/servicetalk-concurrent-api/src/main/java/io/servicetalk/concurrent/api/CompletableMergeSubscriber.java
index 5647ece984..e2ff3aff83 100644
--- a/servicetalk-concurrent-api/src/main/java/io/servicetalk/concurrent/api/CompletableMergeSubscriber.java
+++ b/servicetalk-concurrent-api/src/main/java/io/servicetalk/concurrent/api/CompletableMergeSubscriber.java
@@ -21,6 +21,7 @@
 import java.util.concurrent.atomic.AtomicReferenceFieldUpdater;
 import javax.annotation.Nullable;
 
+import static io.servicetalk.utils.internal.ThrowableUtils.addSuppressed;
 import static java.util.concurrent.atomic.AtomicReferenceFieldUpdater.newUpdater;
 
 abstract class CompletableMergeSubscriber implements Subscriber {
@@ -68,9 +69,7 @@ public final void onError(Throwable t) {
                     return;
                 }
             } else {
-                Throwable tmpT = (Throwable) terminalNotification;
-                tmpT.addSuppressed(t);
-                t = tmpT;
+                t = addSuppressed((Throwable) terminalNotification, t);
                 break;
             }
         }
diff --git a/servicetalk-concurrent-api/src/main/java/io/servicetalk/concurrent/api/CompositeCancellable.java b/servicetalk-concurrent-api/src/main/java/io/servicetalk/concurrent/api/CompositeCancellable.java
index 9f6389e7a0..9aa16dae87 100644
--- a/servicetalk-concurrent-api/src/main/java/io/servicetalk/concurrent/api/CompositeCancellable.java
+++ b/servicetalk-concurrent-api/src/main/java/io/servicetalk/concurrent/api/CompositeCancellable.java
@@ -20,6 +20,7 @@
 import java.util.concurrent.atomic.AtomicIntegerFieldUpdater;
 
 import static io.servicetalk.utils.internal.PlatformDependent.throwException;
+import static io.servicetalk.utils.internal.ThrowableUtils.addSuppressed;
 import static java.util.Objects.requireNonNull;
 
 /**
@@ -56,7 +57,7 @@ public void cancel() {
                     if (t == null) {
                         t = tt;
                     } else {
-                        t.addSuppressed(tt);
+                        addSuppressed(t, tt);
                     }
                 }
             }
diff --git a/servicetalk-concurrent-api/src/main/java/io/servicetalk/concurrent/api/CompositeExceptionUtils.java b/servicetalk-concurrent-api/src/main/java/io/servicetalk/concurrent/api/CompositeExceptionUtils.java
index bc7db72045..7175eb98ac 100644
--- a/servicetalk-concurrent-api/src/main/java/io/servicetalk/concurrent/api/CompositeExceptionUtils.java
+++ b/servicetalk-concurrent-api/src/main/java/io/servicetalk/concurrent/api/CompositeExceptionUtils.java
@@ -17,6 +17,8 @@
 
 import java.util.concurrent.atomic.AtomicIntegerFieldUpdater;
 
+import static io.servicetalk.utils.internal.ThrowableUtils.addSuppressed;
+
 final class CompositeExceptionUtils {
     /**
      * Default to {@code 1} so {@link Throwable#addSuppressed(Throwable)} will not be used by default.
@@ -33,7 +35,7 @@ static <T> void addPendingError(AtomicIntegerFieldUpdater<T> updater, T owner, i
         if (newSize < 0) {
             updater.set(owner, Integer.MAX_VALUE);
         } else if (newSize < maxDelayedErrors && original != causeToAdd) {
-            original.addSuppressed(causeToAdd);
+            addSuppressed(original, causeToAdd);
         } else {
             updater.decrementAndGet(owner);
         }
diff --git a/servicetalk-concurrent-api/src/main/java/io/servicetalk/concurrent/api/OnErrorResumeCompletable.java b/servicetalk-concurrent-api/src/main/java/io/servicetalk/concurrent/api/OnErrorResumeCompletable.java
index 3291807cb2..20f1968538 100644
--- a/servicetalk-concurrent-api/src/main/java/io/servicetalk/concurrent/api/OnErrorResumeCompletable.java
+++ b/servicetalk-concurrent-api/src/main/java/io/servicetalk/concurrent/api/OnErrorResumeCompletable.java
@@ -23,6 +23,7 @@
 import java.util.function.Predicate;
 import javax.annotation.Nullable;
 
+import static io.servicetalk.utils.internal.ThrowableUtils.addSuppressed;
 import static java.util.Objects.requireNonNull;
 
 final class OnErrorResumeCompletable extends AbstractNoHandleSubscribeCompletable {
@@ -86,8 +87,7 @@ public void onError(Throwable throwable) {
                         requireNonNull(parent.nextFactory.apply(throwable)) :
                         null;
             } catch (Throwable t) {
-                t.addSuppressed(throwable);
-                subscriber.onError(t);
+                subscriber.onError(addSuppressed(t, throwable));
                 return;
             }
 
diff --git a/servicetalk-concurrent-api/src/main/java/io/servicetalk/concurrent/api/OnErrorResumePublisher.java b/servicetalk-concurrent-api/src/main/java/io/servicetalk/concurrent/api/OnErrorResumePublisher.java
index 34ddc970e9..23642bae6e 100644
--- a/servicetalk-concurrent-api/src/main/java/io/servicetalk/concurrent/api/OnErrorResumePublisher.java
+++ b/servicetalk-concurrent-api/src/main/java/io/servicetalk/concurrent/api/OnErrorResumePublisher.java
@@ -21,6 +21,7 @@
 import java.util.function.Predicate;
 import javax.annotation.Nullable;
 
+import static io.servicetalk.utils.internal.ThrowableUtils.addSuppressed;
 import static java.util.Objects.requireNonNull;
 
 final class OnErrorResumePublisher<T> extends AbstractNoHandleSubscribePublisher<T> {
@@ -76,18 +77,17 @@ public void onNext(T t) {
         }
 
         @Override
-        public void onError(Throwable t) {
+        public void onError(Throwable throwable) {
             final Publisher<? extends T> next;
             try {
-                next = !resubscribed && predicate.test(t) ? requireNonNull(nextFactory.apply(t)) : null;
-            } catch (Throwable throwable) {
-                throwable.addSuppressed(t);
-                subscriber.onError(throwable);
+                next = !resubscribed && predicate.test(throwable) ? requireNonNull(nextFactory.apply(throwable)) : null;
+            } catch (Throwable t) {
+                subscriber.onError(addSuppressed(t, throwable));
                 return;
             }
 
             if (next == null) {
-                subscriber.onError(t);
+                subscriber.onError(throwable);
             } else {
                 final Subscriber<? super T> offloadedSubscriber =
                         contextProvider.wrapPublisherSubscriber(this, contextMap);
diff --git a/servicetalk-concurrent-api/src/main/java/io/servicetalk/concurrent/api/OnErrorResumeSingle.java b/servicetalk-concurrent-api/src/main/java/io/servicetalk/concurrent/api/OnErrorResumeSingle.java
index 59db57a067..8c92ac938e 100644
--- a/servicetalk-concurrent-api/src/main/java/io/servicetalk/concurrent/api/OnErrorResumeSingle.java
+++ b/servicetalk-concurrent-api/src/main/java/io/servicetalk/concurrent/api/OnErrorResumeSingle.java
@@ -23,6 +23,7 @@
 import java.util.function.Predicate;
 import javax.annotation.Nullable;
 
+import static io.servicetalk.utils.internal.ThrowableUtils.addSuppressed;
 import static java.util.Objects.requireNonNull;
 
 final class OnErrorResumeSingle<T> extends AbstractNoHandleSubscribeSingle<T> {
@@ -81,8 +82,7 @@ public void onError(Throwable throwable) {
             try {
                 next = !resubscribed && predicate.test(throwable) ? requireNonNull(nextFactory.apply(throwable)) : null;
             } catch (Throwable t) {
-                t.addSuppressed(throwable);
-                subscriber.onError(t);
+                subscriber.onError(addSuppressed(t, throwable));
                 return;
             }
 
diff --git a/servicetalk-concurrent-api/src/main/java/io/servicetalk/concurrent/api/RedoPublisher.java b/servicetalk-concurrent-api/src/main/java/io/servicetalk/concurrent/api/RedoPublisher.java
index 15c1d03aef..321f2d529f 100644
--- a/servicetalk-concurrent-api/src/main/java/io/servicetalk/concurrent/api/RedoPublisher.java
+++ b/servicetalk-concurrent-api/src/main/java/io/servicetalk/concurrent/api/RedoPublisher.java
@@ -22,6 +22,7 @@
 import java.util.function.IntPredicate;
 
 import static io.servicetalk.concurrent.internal.TerminalNotification.complete;
+import static io.servicetalk.utils.internal.ThrowableUtils.addSuppressed;
 
 /**
  * {@link Publisher} to do {@link Publisher#repeat(IntPredicate)} and {@link Publisher#retry(BiIntPredicate)}
@@ -116,7 +117,7 @@ private void tryRedo(TerminalNotification notification) {
             } catch (Throwable cause) {
                 Throwable originalCause = notification.cause();
                 if (originalCause != null) {
-                    cause.addSuppressed(originalCause);
+                    addSuppressed(cause, originalCause);
                 }
                 subscriber.onError(cause);
                 return;
diff --git a/servicetalk-concurrent-api/src/main/java/io/servicetalk/concurrent/api/RedoWhenPublisher.java b/servicetalk-concurrent-api/src/main/java/io/servicetalk/concurrent/api/RedoWhenPublisher.java
index 8b528d37c8..b61ff6e9da 100644
--- a/servicetalk-concurrent-api/src/main/java/io/servicetalk/concurrent/api/RedoWhenPublisher.java
+++ b/servicetalk-concurrent-api/src/main/java/io/servicetalk/concurrent/api/RedoWhenPublisher.java
@@ -25,6 +25,7 @@
 import java.util.function.IntFunction;
 
 import static io.servicetalk.concurrent.internal.TerminalNotification.complete;
+import static io.servicetalk.utils.internal.ThrowableUtils.addSuppressed;
 import static java.util.Objects.requireNonNull;
 
 /**
@@ -143,7 +144,7 @@ private void redoIfRequired(TerminalNotification terminalNotification) {
             } catch (Throwable cause) {
                 Throwable originalCause = terminalNotification.cause();
                 if (originalCause != null) {
-                    cause.addSuppressed(originalCause);
+                    addSuppressed(cause, originalCause);
                 }
                 subscriber.onError(cause);
                 return;
diff --git a/servicetalk-concurrent-api/src/main/java/io/servicetalk/concurrent/api/RetrySingle.java b/servicetalk-concurrent-api/src/main/java/io/servicetalk/concurrent/api/RetrySingle.java
index b39ec8cb4a..6d55652d3e 100644
--- a/servicetalk-concurrent-api/src/main/java/io/servicetalk/concurrent/api/RetrySingle.java
+++ b/servicetalk-concurrent-api/src/main/java/io/servicetalk/concurrent/api/RetrySingle.java
@@ -21,6 +21,8 @@
 
 import javax.annotation.Nullable;
 
+import static io.servicetalk.utils.internal.ThrowableUtils.addSuppressed;
+
 /**
  * A {@link Single} implementation as returned by {@link Single#retry(BiIntPredicate)}.
  *
@@ -97,8 +99,7 @@ public void onError(Throwable t) {
             try {
                 shouldRetry = retrySingle.shouldRetry.test(++retryCount, t);
             } catch (Throwable cause) {
-                cause.addSuppressed(t);
-                target.onError(cause);
+                target.onError(addSuppressed(cause, t));
                 return;
             }
             if (shouldRetry) {
diff --git a/servicetalk-concurrent-api/src/main/java/io/servicetalk/concurrent/api/RetryWhenSingle.java b/servicetalk-concurrent-api/src/main/java/io/servicetalk/concurrent/api/RetryWhenSingle.java
index 7b997a0dd7..805d615793 100644
--- a/servicetalk-concurrent-api/src/main/java/io/servicetalk/concurrent/api/RetryWhenSingle.java
+++ b/servicetalk-concurrent-api/src/main/java/io/servicetalk/concurrent/api/RetryWhenSingle.java
@@ -22,6 +22,7 @@
 
 import javax.annotation.Nullable;
 
+import static io.servicetalk.utils.internal.ThrowableUtils.addSuppressed;
 import static java.util.Objects.requireNonNull;
 
 /**
@@ -104,8 +105,7 @@ public void onError(Throwable t) {
             try {
                 retryDecider = requireNonNull(retrySingle.shouldRetry.apply(++retryCount, t));
             } catch (Throwable cause) {
-                cause.addSuppressed(t);
-                target.onError(cause);
+                target.onError(addSuppressed(cause, t));
                 return;
             }
 
diff --git a/servicetalk-concurrent-api/src/testFixtures/java/io/servicetalk/concurrent/api/TestCompletable.java b/servicetalk-concurrent-api/src/testFixtures/java/io/servicetalk/concurrent/api/TestCompletable.java
index badce3f177..71537878ac 100644
--- a/servicetalk-concurrent-api/src/testFixtures/java/io/servicetalk/concurrent/api/TestCompletable.java
+++ b/servicetalk-concurrent-api/src/testFixtures/java/io/servicetalk/concurrent/api/TestCompletable.java
@@ -31,6 +31,7 @@
 import javax.annotation.Nullable;
 
 import static io.servicetalk.utils.internal.PlatformDependent.throwException;
+import static io.servicetalk.utils.internal.ThrowableUtils.addSuppressed;
 import static java.util.Objects.requireNonNull;
 
 /**
@@ -150,7 +151,7 @@ private Subscriber checkSubscriberAndExceptions() {
             final RuntimeException exception = new RuntimeException("Unexpected exception(s) encountered",
                     exceptions.get(0));
             for (int i = 1; i < exceptions.size(); i++) {
-                exception.addSuppressed(exceptions.get(i));
+                addSuppressed(exception, exceptions.get(i));
             }
             throw exception;
         }
diff --git a/servicetalk-concurrent-api/src/testFixtures/java/io/servicetalk/concurrent/api/TestPublisher.java b/servicetalk-concurrent-api/src/testFixtures/java/io/servicetalk/concurrent/api/TestPublisher.java
index 916ceb847c..e43dc65656 100644
--- a/servicetalk-concurrent-api/src/testFixtures/java/io/servicetalk/concurrent/api/TestPublisher.java
+++ b/servicetalk-concurrent-api/src/testFixtures/java/io/servicetalk/concurrent/api/TestPublisher.java
@@ -30,6 +30,7 @@
 import javax.annotation.Nullable;
 
 import static io.servicetalk.utils.internal.PlatformDependent.throwException;
+import static io.servicetalk.utils.internal.ThrowableUtils.addSuppressed;
 import static java.util.Objects.requireNonNull;
 
 /**
@@ -176,7 +177,7 @@ private Subscriber<? super T> checkSubscriberAndExceptions() {
             final RuntimeException exception = new RuntimeException("Unexpected exception(s) encountered",
                     exceptions.get(0));
             for (int i = 1; i < exceptions.size(); i++) {
-                exception.addSuppressed(exceptions.get(i));
+                addSuppressed(exception, exceptions.get(i));
             }
             throw exception;
         }
diff --git a/servicetalk-concurrent-api/src/testFixtures/java/io/servicetalk/concurrent/api/TestSingle.java b/servicetalk-concurrent-api/src/testFixtures/java/io/servicetalk/concurrent/api/TestSingle.java
index d16613b645..4d61626f6e 100644
--- a/servicetalk-concurrent-api/src/testFixtures/java/io/servicetalk/concurrent/api/TestSingle.java
+++ b/servicetalk-concurrent-api/src/testFixtures/java/io/servicetalk/concurrent/api/TestSingle.java
@@ -31,6 +31,7 @@
 
 import static io.servicetalk.concurrent.test.internal.AwaitUtils.await;
 import static io.servicetalk.utils.internal.PlatformDependent.throwException;
+import static io.servicetalk.utils.internal.ThrowableUtils.addSuppressed;
 import static java.util.Objects.requireNonNull;
 
 /**
@@ -153,7 +154,7 @@ private Subscriber<? super T> checkSubscriberAndExceptions() {
             final RuntimeException exception = new RuntimeException("Unexpected exception(s) encountered",
                     exceptions.get(0));
             for (int i = 1; i < exceptions.size(); i++) {
-                exception.addSuppressed(exceptions.get(i));
+                addSuppressed(exception, exceptions.get(i));
             }
             throw exception;
         }
diff --git a/servicetalk-concurrent-internal/src/main/java/io/servicetalk/concurrent/internal/TerminalNotification.java b/servicetalk-concurrent-internal/src/main/java/io/servicetalk/concurrent/internal/TerminalNotification.java
index fdd2a35de3..9d65f7c559 100644
--- a/servicetalk-concurrent-internal/src/main/java/io/servicetalk/concurrent/internal/TerminalNotification.java
+++ b/servicetalk-concurrent-internal/src/main/java/io/servicetalk/concurrent/internal/TerminalNotification.java
@@ -21,6 +21,7 @@
 import java.util.Objects;
 import javax.annotation.Nullable;
 
+import static io.servicetalk.utils.internal.ThrowableUtils.addSuppressed;
 import static java.util.Objects.requireNonNull;
 
 /**
@@ -80,8 +81,7 @@ public void terminate(PublisherSource.Subscriber<?> subscriber, Throwable additi
             subscriber.onError(additionalCause);
         } else {
             assert cause != null;
-            cause.addSuppressed(additionalCause);
-            subscriber.onError(cause);
+            subscriber.onError(addSuppressed(cause, additionalCause));
         }
     }
 
@@ -102,8 +102,7 @@ public void terminate(Subscriber subscriber, Throwable additionalCause) {
             subscriber.onError(additionalCause);
         } else {
             assert cause != null;
-            cause.addSuppressed(additionalCause);
-            subscriber.onError(cause);
+            subscriber.onError(addSuppressed(cause, additionalCause));
         }
     }
 
diff --git a/servicetalk-dns-discovery-netty/src/main/java/io/servicetalk/dns/discovery/netty/DefaultDnsClient.java b/servicetalk-dns-discovery-netty/src/main/java/io/servicetalk/dns/discovery/netty/DefaultDnsClient.java
index 8e3e4ef7f2..c91f269af7 100644
--- a/servicetalk-dns-discovery-netty/src/main/java/io/servicetalk/dns/discovery/netty/DefaultDnsClient.java
+++ b/servicetalk-dns-discovery-netty/src/main/java/io/servicetalk/dns/discovery/netty/DefaultDnsClient.java
@@ -90,6 +90,7 @@
 import static io.servicetalk.transport.netty.internal.BuilderUtils.datagramChannel;
 import static io.servicetalk.transport.netty.internal.BuilderUtils.socketChannel;
 import static io.servicetalk.transport.netty.internal.EventLoopAwareNettyIoExecutors.toEventLoopAwareNettyIoExecutor;
+import static io.servicetalk.utils.internal.ThrowableUtils.addSuppressed;
 import static java.nio.ByteBuffer.wrap;
 import static java.util.Collections.emptyList;
 import static java.util.Collections.emptyMap;
@@ -698,7 +699,7 @@ private void reportResolutionFailed(@Nullable final DnsResolutionObserver resolu
                 try {
                     resolutionObserver.resolutionFailed(cause);
                 } catch (Throwable unexpected) {
-                    unexpected.addSuppressed(cause);
+                    addSuppressed(unexpected, cause);
                     LOGGER.warn("Unexpected exception from {} while reporting DNS resolution failure",
                             resolutionObserver, unexpected);
                 }
diff --git a/servicetalk-grpc-netty/src/test/java/io/servicetalk/grpc/netty/ProtocolCompatibilityTest.java b/servicetalk-grpc-netty/src/test/java/io/servicetalk/grpc/netty/ProtocolCompatibilityTest.java
index 897be0c627..66cdfe088f 100644
--- a/servicetalk-grpc-netty/src/test/java/io/servicetalk/grpc/netty/ProtocolCompatibilityTest.java
+++ b/servicetalk-grpc-netty/src/test/java/io/servicetalk/grpc/netty/ProtocolCompatibilityTest.java
@@ -126,6 +126,7 @@
 import static io.servicetalk.test.resources.DefaultTestCerts.serverPemHostname;
 import static io.servicetalk.transport.api.SslProvider.OPENSSL;
 import static io.servicetalk.transport.netty.internal.AddressUtils.localAddress;
+import static io.servicetalk.utils.internal.ThrowableUtils.addSuppressed;
 import static java.time.Duration.ofMillis;
 import static java.util.Arrays.asList;
 import static java.util.concurrent.TimeUnit.NANOSECONDS;
@@ -980,7 +981,7 @@ private static void closeAll(final AutoCloseable... acs) {
                 if (re == null) {
                     re = new RuntimeException("Failure(s) when closing: " + Arrays.toString(acs));
                 }
-                re.addSuppressed(t);
+                addSuppressed(re, t);
             }
         }
 
diff --git a/servicetalk-http-api/src/main/java/io/servicetalk/http/api/HttpDataSourceTransformations.java b/servicetalk-http-api/src/main/java/io/servicetalk/http/api/HttpDataSourceTransformations.java
index 95e7d9984f..84a86dae82 100644
--- a/servicetalk-http-api/src/main/java/io/servicetalk/http/api/HttpDataSourceTransformations.java
+++ b/servicetalk-http-api/src/main/java/io/servicetalk/http/api/HttpDataSourceTransformations.java
@@ -40,6 +40,7 @@
 import static io.servicetalk.concurrent.api.Single.succeeded;
 import static io.servicetalk.concurrent.api.SourceAdapters.toSource;
 import static io.servicetalk.concurrent.internal.SubscriberUtils.checkDuplicateSubscription;
+import static io.servicetalk.utils.internal.ThrowableUtils.addSuppressed;
 import static java.lang.Integer.MAX_VALUE;
 import static java.lang.System.nanoTime;
 import static java.util.Objects.requireNonNull;
@@ -240,7 +241,7 @@ private boolean validateNext(@Nullable Object next) {
                 try {
                     iterator.close();
                 } catch (Throwable cause) {
-                    e.addSuppressed(cause);
+                    addSuppressed(e, cause);
                 }
                 throw e;
             }
diff --git a/servicetalk-http-netty/src/main/java/io/servicetalk/http/netty/AbstractLifecycleObserverHttpFilter.java b/servicetalk-http-netty/src/main/java/io/servicetalk/http/netty/AbstractLifecycleObserverHttpFilter.java
index 40e6183fb5..2deb50510d 100644
--- a/servicetalk-http-netty/src/main/java/io/servicetalk/http/netty/AbstractLifecycleObserverHttpFilter.java
+++ b/servicetalk-http-netty/src/main/java/io/servicetalk/http/netty/AbstractLifecycleObserverHttpFilter.java
@@ -49,6 +49,7 @@
 
 import static io.servicetalk.concurrent.api.Single.defer;
 import static io.servicetalk.context.api.ContextMap.Key.newKey;
+import static io.servicetalk.utils.internal.ThrowableUtils.addSuppressed;
 import static java.util.Objects.requireNonNull;
 
 abstract class AbstractLifecycleObserverHttpFilter implements HttpExecutionStrategyInfluencer {
@@ -288,7 +289,7 @@ private static void safeReport(final Consumer<Throwable> onError, final Throwabl
         try {
             onError.accept(t);
         } catch (Throwable unexpected) {
-            unexpected.addSuppressed(t);
+            addSuppressed(unexpected, t);
             LOGGER.warn("Unexpected exception from {} while reporting a '{}' event", observer, eventName, unexpected);
         }
     }
diff --git a/servicetalk-http-netty/src/main/java/io/servicetalk/http/netty/H2ClientParentConnectionContext.java b/servicetalk-http-netty/src/main/java/io/servicetalk/http/netty/H2ClientParentConnectionContext.java
index cd3b7fd7b3..0f83332bc1 100644
--- a/servicetalk-http-netty/src/main/java/io/servicetalk/http/netty/H2ClientParentConnectionContext.java
+++ b/servicetalk-http-netty/src/main/java/io/servicetalk/http/netty/H2ClientParentConnectionContext.java
@@ -89,6 +89,7 @@
 import static io.servicetalk.transport.netty.internal.ChannelCloseUtils.close;
 import static io.servicetalk.transport.netty.internal.ChannelSet.CHANNEL_CLOSEABLE_KEY;
 import static io.servicetalk.transport.netty.internal.CloseHandler.forNonPipelined;
+import static io.servicetalk.utils.internal.ThrowableUtils.addSuppressed;
 import static java.util.Objects.requireNonNull;
 
 final class H2ClientParentConnectionContext extends H2ParentConnectionContext {
@@ -375,7 +376,7 @@ private void childChannelActive(Future<Http2StreamChannel> future,
                         try {
                             close(streamChannel, cause);
                         } catch (Throwable unexpected) {
-                            unexpected.addSuppressed(cause);
+                            addSuppressed(unexpected, cause);
                             LOGGER.warn("Unexpected exception while handling the original cause", unexpected);
                         }
                     } else {
diff --git a/servicetalk-http-utils/src/main/java/io/servicetalk/http/utils/BeforeFinallyHttpOperator.java b/servicetalk-http-utils/src/main/java/io/servicetalk/http/utils/BeforeFinallyHttpOperator.java
index 4f3cea2583..7ef0a1d959 100644
--- a/servicetalk-http-utils/src/main/java/io/servicetalk/http/utils/BeforeFinallyHttpOperator.java
+++ b/servicetalk-http-utils/src/main/java/io/servicetalk/http/utils/BeforeFinallyHttpOperator.java
@@ -32,6 +32,7 @@
 import javax.annotation.Nullable;
 
 import static io.servicetalk.concurrent.api.SourceAdapters.toSource;
+import static io.servicetalk.utils.internal.ThrowableUtils.addSuppressed;
 import static java.util.Objects.requireNonNull;
 import static java.util.concurrent.atomic.AtomicIntegerFieldUpdater.newUpdater;
 
@@ -281,7 +282,7 @@ public void onError(final Throwable t) {
                                                     beforeFinally.onError(t);
                                                 }
                                             } catch (Throwable cause) {
-                                                t.addSuppressed(cause);
+                                                addSuppressed(t, cause);
                                             }
                                             subscriber.onError(t);
                                             return;
@@ -298,7 +299,7 @@ public void onError(final Throwable t) {
                                         try {
                                             beforeFinally.onError(t);
                                         } catch (Throwable cause) {
-                                            t.addSuppressed(cause);
+                                            addSuppressed(t, cause);
                                         }
                                         try {
                                             subscriber.onError(t);
@@ -398,7 +399,7 @@ public void onError(final Throwable t) {
                     return;
                 }
             } catch (Throwable cause) {
-                t.addSuppressed(cause);
+                addSuppressed(t, cause);
             }
             subscriber.onError(t);
         }
diff --git a/servicetalk-serialization-api/build.gradle b/servicetalk-serialization-api/build.gradle
index 6e563cd0b9..e6f9526997 100644
--- a/servicetalk-serialization-api/build.gradle
+++ b/servicetalk-serialization-api/build.gradle
@@ -26,6 +26,7 @@ dependencies {
   implementation project(":servicetalk-annotations")
   implementation project(":servicetalk-concurrent-api-internal")
   implementation project(":servicetalk-concurrent-internal")
+  implementation project(":servicetalk-utils-internal")
   implementation "com.google.code.findbugs:jsr305:$jsr305Version"
 
   testImplementation testFixtures(project(":servicetalk-concurrent-api"))
diff --git a/servicetalk-serialization-api/src/main/java/io/servicetalk/serialization/api/DefaultSerializer.java b/servicetalk-serialization-api/src/main/java/io/servicetalk/serialization/api/DefaultSerializer.java
index f19a1955e2..f2d5c1f56b 100644
--- a/servicetalk-serialization-api/src/main/java/io/servicetalk/serialization/api/DefaultSerializer.java
+++ b/servicetalk-serialization-api/src/main/java/io/servicetalk/serialization/api/DefaultSerializer.java
@@ -35,6 +35,7 @@
 import javax.annotation.Nullable;
 
 import static io.servicetalk.concurrent.api.SourceAdapters.toSource;
+import static io.servicetalk.utils.internal.ThrowableUtils.addSuppressed;
 import static java.lang.Integer.MAX_VALUE;
 import static java.lang.Math.max;
 import static java.lang.Math.min;
@@ -326,7 +327,7 @@ private static <S, T> CloseableIterable<T> deserializeAndClose(final S source,
             try {
                 deSerializer.close();
             } catch (SerializationException e) {
-                throwable.addSuppressed(e);
+                addSuppressed(throwable, e);
             }
             throw throwable;
         }
@@ -352,7 +353,7 @@ private static void closeIterator(CloseableIterator<?> iterator, @Nullable Seria
             iterator.close(); // May throw in case of incomplete accumulated data
         } catch (Exception e) {
             if (cause != null) {
-                cause.addSuppressed(e);
+                addSuppressed(cause, e);
                 throw cause;
             }
             if (e instanceof SerializationException) {
diff --git a/servicetalk-test-resources/build.gradle b/servicetalk-test-resources/build.gradle
index 06a26b6486..e58bbb6319 100644
--- a/servicetalk-test-resources/build.gradle
+++ b/servicetalk-test-resources/build.gradle
@@ -19,11 +19,12 @@ apply plugin: "io.servicetalk.servicetalk-gradle-plugin-internal-library"
 dependencies {
   testImplementation enforcedPlatform("org.junit:junit-bom:$junit5Version")
 
-  implementation project(":servicetalk-annotations")
-
   api "org.apache.logging.log4j:log4j-core:$log4jVersion"
   api "org.apache.logging.log4j:log4j-slf4j-impl:$log4jVersion"
   api "org.hamcrest:hamcrest:$hamcrestVersion"
 
+  implementation project(":servicetalk-annotations")
+  implementation project(":servicetalk-utils-internal")
+
   testImplementation "org.junit.jupiter:junit-jupiter-api"
 }
diff --git a/servicetalk-test-resources/src/main/java/io/servicetalk/test/resources/TestUtils.java b/servicetalk-test-resources/src/main/java/io/servicetalk/test/resources/TestUtils.java
index 0c1158d1bf..c153bded15 100644
--- a/servicetalk-test-resources/src/main/java/io/servicetalk/test/resources/TestUtils.java
+++ b/servicetalk-test-resources/src/main/java/io/servicetalk/test/resources/TestUtils.java
@@ -21,6 +21,7 @@
 
 import java.util.Queue;
 
+import static io.servicetalk.utils.internal.ThrowableUtils.addSuppressed;
 import static java.lang.Integer.min;
 
 /**
@@ -57,7 +58,7 @@ public static void assertNoAsyncErrors(final String message, final Queue<? exten
         final AssertionError error = null != message ? new AssertionError(message) : new AssertionError();
         Throwable t;
         while ((t = errors.poll()) != null) {
-            error.addSuppressed(t);
+            addSuppressed(error, t);
         }
 
         throw error;
diff --git a/servicetalk-transport-api/build.gradle b/servicetalk-transport-api/build.gradle
index ac138589f4..3c356805d7 100644
--- a/servicetalk-transport-api/build.gradle
+++ b/servicetalk-transport-api/build.gradle
@@ -24,6 +24,7 @@ dependencies {
 
   implementation project(":servicetalk-annotations")
   implementation project(":servicetalk-concurrent-internal")
+  implementation project(":servicetalk-utils-internal")
   implementation "com.google.code.findbugs:jsr305:$jsr305Version"
   implementation "org.slf4j:slf4j-api:$slf4jVersion"
 
diff --git a/servicetalk-transport-api/src/main/java/io/servicetalk/transport/api/CatchAllTransportObserver.java b/servicetalk-transport-api/src/main/java/io/servicetalk/transport/api/CatchAllTransportObserver.java
index 1a5ceb5cc2..9236e86239 100644
--- a/servicetalk-transport-api/src/main/java/io/servicetalk/transport/api/CatchAllTransportObserver.java
+++ b/servicetalk-transport-api/src/main/java/io/servicetalk/transport/api/CatchAllTransportObserver.java
@@ -37,6 +37,7 @@
 import javax.annotation.Nullable;
 import javax.net.ssl.SSLSession;
 
+import static io.servicetalk.utils.internal.ThrowableUtils.addSuppressed;
 import static java.util.Objects.requireNonNull;
 
 /**
@@ -307,7 +308,7 @@ private static void safeReport(final Runnable runnable, final Object observer, f
         try {
             runnable.run();
         } catch (Throwable unexpected) {
-            unexpected.addSuppressed(original);
+            addSuppressed(unexpected, original);
             LOGGER.warn("Unexpected exception from {} while reporting a {} event", observer, eventName, unexpected);
         }
     }
diff --git a/servicetalk-transport-netty-internal/build.gradle b/servicetalk-transport-netty-internal/build.gradle
index eb227fa67b..39ef0cd5de 100644
--- a/servicetalk-transport-netty-internal/build.gradle
+++ b/servicetalk-transport-netty-internal/build.gradle
@@ -59,6 +59,7 @@ dependencies {
   testImplementation "org.mockito:mockito-core:$mockitoCoreVersion"
   testImplementation "org.mockito:mockito-junit-jupiter:$mockitoCoreVersion"
 
+  testFixturesImplementation project(":servicetalk-utils-internal")
   testFixturesImplementation "io.netty.incubator:netty-incubator-transport-native-io_uring:$nettyIoUringVersion"
   testFixturesImplementation "com.google.code.findbugs:jsr305:$jsr305Version"
   testFixturesImplementation "org.junit.jupiter:junit-jupiter-api"
diff --git a/servicetalk-transport-netty-internal/src/main/java/io/servicetalk/transport/netty/internal/Flush.java b/servicetalk-transport-netty-internal/src/main/java/io/servicetalk/transport/netty/internal/Flush.java
index 074ba5b4f0..fd2342e7c1 100644
--- a/servicetalk-transport-netty-internal/src/main/java/io/servicetalk/transport/netty/internal/Flush.java
+++ b/servicetalk-transport-netty-internal/src/main/java/io/servicetalk/transport/netty/internal/Flush.java
@@ -24,6 +24,7 @@
 import io.netty.channel.Channel;
 import io.netty.util.concurrent.EventExecutor;
 
+import static io.servicetalk.utils.internal.ThrowableUtils.addSuppressed;
 import static java.util.Objects.requireNonNull;
 
 /**
@@ -122,7 +123,7 @@ public void onError(Throwable t) {
             try {
                 writeEventsListener.writeTerminated();
             } catch (Throwable t1) {
-                t.addSuppressed(t1);
+                addSuppressed(t, t1);
             }
             subscriber.onError(t);
         }
diff --git a/servicetalk-transport-netty-internal/src/main/java/io/servicetalk/transport/netty/internal/WriteStreamSubscriber.java b/servicetalk-transport-netty-internal/src/main/java/io/servicetalk/transport/netty/internal/WriteStreamSubscriber.java
index dd9154ef50..3e7cd4c3bb 100644
--- a/servicetalk-transport-netty-internal/src/main/java/io/servicetalk/transport/netty/internal/WriteStreamSubscriber.java
+++ b/servicetalk-transport-netty-internal/src/main/java/io/servicetalk/transport/netty/internal/WriteStreamSubscriber.java
@@ -47,6 +47,7 @@
 import static io.servicetalk.transport.netty.internal.ByteMaskUtils.isAnySet;
 import static io.servicetalk.transport.netty.internal.ByteMaskUtils.set;
 import static io.servicetalk.transport.netty.internal.ChannelCloseUtils.assignConnectionError;
+import static io.servicetalk.utils.internal.ThrowableUtils.addSuppressed;
 import static java.util.Objects.requireNonNull;
 
 /**
@@ -566,7 +567,7 @@ private void terminateSubscriber(@Nullable Throwable cause) {
                     observer.writeFailed(enrichedCause);
                     subscriber.onError(enrichedCause);
                 } catch (Throwable t) {
-                    t.addSuppressed(enrichedCause);
+                    addSuppressed(t, enrichedCause);
                     tryFailureOrLog(t);
                 }
                 if (!isAllSet(state, CHANNEL_CLOSED)) {
diff --git a/servicetalk-transport-netty-internal/src/testFixtures/java/io/servicetalk/transport/netty/internal/EmbeddedDuplexChannel.java b/servicetalk-transport-netty-internal/src/testFixtures/java/io/servicetalk/transport/netty/internal/EmbeddedDuplexChannel.java
index 341673a18d..d17142606f 100644
--- a/servicetalk-transport-netty-internal/src/testFixtures/java/io/servicetalk/transport/netty/internal/EmbeddedDuplexChannel.java
+++ b/servicetalk-transport-netty-internal/src/testFixtures/java/io/servicetalk/transport/netty/internal/EmbeddedDuplexChannel.java
@@ -45,6 +45,7 @@
 import javax.annotation.Nullable;
 
 import static io.netty.channel.ChannelOption.ALLOW_HALF_CLOSURE;
+import static io.servicetalk.utils.internal.ThrowableUtils.addSuppressed;
 
 /**
  * {@link EmbeddedChannel} that implements {@link DuplexChannel}.
@@ -313,7 +314,7 @@ private static void shutdownDone(ChannelFuture shutdownOutputFuture,
         Throwable shutdownInputCause = shutdownInputFuture.cause();
         if (shutdownOutputCause != null) {
             if (shutdownInputCause != null) {
-                shutdownOutputCause.addSuppressed(shutdownInputCause);
+                addSuppressed(shutdownOutputCause, shutdownInputCause);
             }
             promise.setFailure(shutdownOutputCause);
         } else if (shutdownInputCause != null) {
diff --git a/servicetalk-utils-internal/src/main/java/io/servicetalk/utils/internal/ThrowableUtils.java b/servicetalk-utils-internal/src/main/java/io/servicetalk/utils/internal/ThrowableUtils.java
index ed9fb9be4c..ba755b7af2 100644
--- a/servicetalk-utils-internal/src/main/java/io/servicetalk/utils/internal/ThrowableUtils.java
+++ b/servicetalk-utils-internal/src/main/java/io/servicetalk/utils/internal/ThrowableUtils.java
@@ -39,9 +39,7 @@ private ThrowableUtils() {
     public static Throwable combine(@Nullable final Object first, @Nullable final Object second) {
         if (first instanceof Throwable) {
             if (second instanceof Throwable) {
-                final Throwable result = (Throwable) first;
-                result.addSuppressed((Throwable) second);
-                return result;
+                return addSuppressed((Throwable) first, (Throwable) second);
             } else {
                 return (Throwable) first;
             }
@@ -51,4 +49,18 @@ public static Throwable combine(@Nullable final Object first, @Nullable final Ob
             return null;
         }
     }
+
+    /**
+     * Adds suppressed exception avoiding self-suppression.
+     *
+     * @param original the original {@link Throwable}
+     * @param suppressed the {@link Throwable} to be suppressed
+     * @return the original {@link Throwable}
+     */
+    public static Throwable addSuppressed(final Throwable original, final Throwable suppressed) {
+        if (original != suppressed) {
+            original.addSuppressed(suppressed);
+        }
+        return original;
+    }
 }