diff --git a/ozgcloud-common-lib/src/main/java/de/ozgcloud/common/binaryfile/StreamingFileSender.java b/ozgcloud-common-lib/src/main/java/de/ozgcloud/common/binaryfile/StreamingFileSender.java index 9d0440e9e843f696a1a801a6f664c9aa3c86b163..dc2af678a0551c037aaef779853024fe39d7e3e8 100644 --- a/ozgcloud-common-lib/src/main/java/de/ozgcloud/common/binaryfile/StreamingFileSender.java +++ b/ozgcloud-common-lib/src/main/java/de/ozgcloud/common/binaryfile/StreamingFileSender.java @@ -125,7 +125,7 @@ public abstract class StreamingFileSender<Q, S> { } } - protected void endTransfer() { + void endTransfer() { communicateEndOfTransfer(); done.set(true); LOG.debug("File Transfer done."); diff --git a/ozgcloud-common-lib/src/test/java/de/ozgcloud/common/binaryfile/StreamingFileSenderTest.java b/ozgcloud-common-lib/src/test/java/de/ozgcloud/common/binaryfile/StreamingFileSenderTest.java index f369aabc659585ba3444a42c5088edbc6be651a5..32bd933b7d482f3004e3d9d5214cbf54d669a264 100644 --- a/ozgcloud-common-lib/src/test/java/de/ozgcloud/common/binaryfile/StreamingFileSenderTest.java +++ b/ozgcloud-common-lib/src/test/java/de/ozgcloud/common/binaryfile/StreamingFileSenderTest.java @@ -125,7 +125,7 @@ class StreamingFileSenderTest { } @Test - void shouldCallSendMetaData() { + void shouldSendMetaData() { fileSender.sendNext(); verify(fileSender).sendMetaData(); @@ -157,7 +157,7 @@ class StreamingFileSenderTest { } @Test - void shouldCallSendChunk() { + void shouldSendChunk() { fileSender.sendNextChunk(); verify(fileSender).sendChunk(chunkCaptor.capture(), eq(content.length)); @@ -176,18 +176,17 @@ class StreamingFileSenderTest { } @Test - void shouldNotCallSendChunk() { + void shouldNotSendChunk() { fileSender.sendNextChunk(); verify(fileSender, never()).sendChunk(any(), anyInt()); } @Test - @SneakyThrows - void shouldCallCloseStreams() { + void shouldEndTransfer() { fileSender.sendNextChunk(); - verify(fileSender).closeStreamReader(); + verify(fileSender).endTransfer(); } } } @@ -211,7 +210,7 @@ class StreamingFileSenderTest { } @Test - void shouldCloseStreams() { + void shouldCloseStreamReader() { fileSender.endTransfer(); verify(fileSender).closeStreamReader();