init variable

streamnative · Jan 14, 2025 · df092ac · df092ac
1 parent f9510da
commit df092ac
Showing 1 changed file with 2 additions 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
@@ -38,7 +38,8 @@ public final class WriteStreamWrapper implements StreamObserver<WriteResponse> {
     public WriteStreamWrapper(OxiaClientGrpc.OxiaClientStub stub) {
         this.clientStream = stub.writeStream(this);
         this.pendingWrites = new ArrayDeque<>();
-
+        this.completed = false;
+        this.completedException = null;
     }
 
     public boolean isValid() {