Skip to content

Commit f7cada9

Browse files
committed
only check for 0 buffer length
1 parent 296c916 commit f7cada9

File tree

1 file changed

+4
-3
lines changed

1 file changed

+4
-3
lines changed

core/sdk-core/src/main/java/software/amazon/awssdk/core/internal/async/ByteBuffersAsyncRequestBody.java

Lines changed: 4 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -86,10 +86,11 @@ public void request(long n) {
8686
if (n > 0) {
8787
int i = index.getAndIncrement();
8888

89+
if (buffers.length == 0 && completed.compareAndSet(false, true)) {
90+
s.onComplete();
91+
}
92+
8993
if (i >= buffers.length) {
90-
if (completed.compareAndSet(false, true)) {
91-
s.onComplete();
92-
}
9394
return;
9495
}
9596

0 commit comments

Comments
 (0)