m

Lucas McDonald · Lucas McDonald · commit daf14932aa4c · 2025-04-28T15:16:43.000-07:00
diff --git a/src/main/java/software/amazon/encryption/s3/internal/CipherSubscriber.java b/src/main/java/software/amazon/encryption/s3/internal/CipherSubscriber.java
@@ -66,6 +66,7 @@ public void onNext(ByteBuffer byteBuffer) {
                 } else {
                     // Done, wait for upstream to signal onComplete
                     System.out.println("[CipherSubscriber] All content read (contentRead: " + contentRead.get() + ", contentLength: " + contentLength + "), waiting for onComplete");
+                    this.onComplete();
                 }
             }
         } else {

Original file line number	Diff line number	Diff line change
`@@ -66,6 +66,7 @@ public void onNext(ByteBuffer byteBuffer) {`
`66`	`66`	`} else {`
`67`	`67`	`// Done, wait for upstream to signal onComplete`
`68`	`68`	`System.out.println("[CipherSubscriber] All content read (contentRead: " + contentRead.get() + ", contentLength: " + contentLength + "), waiting for onComplete");`
	`69`	`+ this.onComplete();`
`69`	`70`	`}`
`70`	`71`	`}`
`71`	`72`	`} else {`