fix: completed status overrided by fail-fast stream (#201)

fix: fix status overrided by fail-fast stream
streamnative · Jan 16, 2025 · cf1f5ea · cf1f5ea
1 parent 7087880
commit cf1f5ea
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
@@ -36,10 +36,10 @@ public final class WriteStreamWrapper implements StreamObserver<WriteResponse> {
     private volatile Throwable completedException;
 
     public WriteStreamWrapper(OxiaClientGrpc.OxiaClientStub stub) {
-        this.clientStream = stub.writeStream(this);
         this.pendingWrites = new ArrayDeque<>();
         this.completed = false;
         this.completedException = null;
+        this.clientStream = stub.writeStream(this);
     }
 
     public boolean isValid() {