use same exception

streamnative · Jan 14, 2025 · 352ed4c · 352ed4c
1 parent 1f22fa6
commit 352ed4c
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/client/src/main/java/io/streamnative/oxia/client/grpc/WriteStreamWrapper.java b/client/src/main/java/io/streamnative/oxia/client/grpc/WriteStreamWrapper.java
@@ -93,7 +93,7 @@ public void onError(Throwable ex) {
                         pendingWrites.size(),
                         completedException);
             }
-            pendingWrites.forEach(f -> f.completeExceptionally(ex));
+            pendingWrites.forEach(f -> f.completeExceptionally(completedException));
             pendingWrites.clear();
         } finally {
             statusLock.unlockWrite(stamp);