(skywalking-banyandb-java-client) branch main updated: Fix timer doesn't finish (#92)

[hanahmily]

This is an automated email from the ASF dual-hosted git repository.

hanahmily pushed a commit to branch main
in repository 
https://gitbox.apache.org/repos/asf/skywalking-banyandb-java-client.git


The following commit(s) were added to refs/heads/main by this push:
     new 0a6fa28  Fix timer doesn't finish (#92)
0a6fa28 is described below

commit 0a6fa2823965899de05c36b6a61cd68330bf3f03
Author: 吴晟 Wu Sheng <wu.sh...@foxmail.com>
AuthorDate: Wed Aug 27 07:45:42 2025 +0800

    Fix timer doesn't finish (#92)
    
    * Add write obs for client.
---
 .../apache/skywalking/banyandb/v1/client/AbstractBulkWriteProcessor.java | 1 +
 1 file changed, 1 insertion(+)

diff --git 
a/src/main/java/org/apache/skywalking/banyandb/v1/client/AbstractBulkWriteProcessor.java
 
b/src/main/java/org/apache/skywalking/banyandb/v1/client/AbstractBulkWriteProcessor.java
index 5c66cda..d850cd1 100644
--- 
a/src/main/java/org/apache/skywalking/banyandb/v1/client/AbstractBulkWriteProcessor.java
+++ 
b/src/main/java/org/apache/skywalking/banyandb/v1/client/AbstractBulkWriteProcessor.java
@@ -170,6 +170,7 @@ public abstract class AbstractBulkWriteProcessor<REQ 
extends com.google.protobuf
             writeRequestStreamObserver.onCompleted();
         }
         batch.whenComplete((ignored, exp) -> {
+            timer.observeDuration();
             if (exp != null) {
                 log.error("Failed to execute requests in bulk", exp);
             }