feat(s3stream): optimize the execution sequence to avoid deep depende… (

#1790) * feat(s3stream): optimize the execution sequence to avoid deep dependencies * feat(s3stream): optimize the execution sequence to avoid deep dependencies * feat(s3stream): optimize the execution sequence * feat(s3stream): optimize the execution sequence * feat(s3stream): optimize the execution sequence
AutoMQ · Aug 15, 2024 · f070e4e · f070e4e
1 parent 23d7c02
commit f070e4e
Showing 1 changed file with 1 addition and 2 deletions.
diff --git a/s3stream/src/main/java/com/automq/stream/s3/S3Stream.java b/s3stream/src/main/java/com/automq/stream/s3/S3Stream.java
@@ -162,12 +162,11 @@ public CompletableFuture<AppendResult> append(AppendContext context, RecordBatch
             }, LOGGER, "append");
             pendingAppends.add(cf);
             pendingAppendTimestamps.push(startTimeNanos);
-            cf.whenComplete((nil, ex) -> {
+            return cf.whenComplete((nil, ex) -> {
                 StreamOperationStats.getInstance().appendStreamLatency.record(TimerUtil.durationElapsedAs(startTimeNanos, TimeUnit.NANOSECONDS));
                 pendingAppends.remove(cf);
                 pendingAppendTimestamps.pop();
             });
-            return cf;
         } finally {
             readLock.unlock();
         }