diff --git a/ozgcloud-common-lib/src/main/java/de/ozgcloud/common/binaryfile/GrpcBinaryFileServerDownloader.java b/ozgcloud-common-lib/src/main/java/de/ozgcloud/common/binaryfile/GrpcBinaryFileServerDownloader.java index 49f72606a3afc7f0534f98405406fb1be1f0668f..b6bff4a9ca59e8ff7818317a15d176c1660fd695 100644 --- a/ozgcloud-common-lib/src/main/java/de/ozgcloud/common/binaryfile/GrpcBinaryFileServerDownloader.java +++ b/ozgcloud-common-lib/src/main/java/de/ozgcloud/common/binaryfile/GrpcBinaryFileServerDownloader.java @@ -133,9 +133,6 @@ public class GrpcBinaryFileServerDownloader<T> { } void completeRequest() { - if (requestFinished.getAndSet(true)) { - return; - } LOG.debug("Complete download request"); closeInputStream(); callObserver.onCompleted(); diff --git a/ozgcloud-common-lib/src/test/java/de/ozgcloud/common/binaryfile/GrpcBinaryFileServerDownloaderTest.java b/ozgcloud-common-lib/src/test/java/de/ozgcloud/common/binaryfile/GrpcBinaryFileServerDownloaderTest.java index 215303f04a0d8312d085725a0506ca20cae35ca1..2cda081844610772cc19da6b76a6b52ad71d5b1b 100644 --- a/ozgcloud-common-lib/src/test/java/de/ozgcloud/common/binaryfile/GrpcBinaryFileServerDownloaderTest.java +++ b/ozgcloud-common-lib/src/test/java/de/ozgcloud/common/binaryfile/GrpcBinaryFileServerDownloaderTest.java @@ -416,13 +416,6 @@ class GrpcBinaryFileServerDownloaderTest { setInputStreamField(inputStream); } - @Test - void shouldSetSendingFinished() { - downloader.completeRequest(); - - assertThat(getRequestFinished()).isTrue(); - } - @SneakyThrows @Test void shouldCallCloseInputStream() {