Cancel subscription when buffer gets freed

deephaven · Jun 21, 2024 · 6a0da89 · 6a0da89
1 parent e293af1
commit 6a0da89
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/extensions/s3/src/main/java/io/deephaven/extensions/s3/S3Request.java b/extensions/s3/src/main/java/io/deephaven/extensions/s3/S3Request.java
@@ -368,6 +368,7 @@ public void onNext(final ByteBuffer dataBuffer) {
             final ByteBuffer resultBuffer = S3Request.this.get();
             if (resultBuffer == null) {
                 localProducer.complete(false);
+                subscription.cancel();
                 return;
             }
             final int numBytes = dataBuffer.remaining();