diff --git a/src/main/java/org/gcube/data/access/storagehub/MultipleOutputStream.java b/src/main/java/org/gcube/data/access/storagehub/MultipleOutputStream.java index de60e49..e902eb3 100644 --- a/src/main/java/org/gcube/data/access/storagehub/MultipleOutputStream.java +++ b/src/main/java/org/gcube/data/access/storagehub/MultipleOutputStream.java @@ -44,17 +44,15 @@ public class MultipleOutputStream { while ((read =bis.read(buf))!=-1){ for (int i=0; i< pipedInStreams.length; i++) { if (!pipedInStreams[i].isClosed()) { - logger.debug("writing into piped stream {} ",i); pipedOutStreams[i].write(buf, 0, read); } } writeTot+= read; - if (allOutStreamClosed()) { - logger.debug("all streams created are closed"); + if (allOutStreamClosed()) break; - } else logger.debug("NOT all streams created are closed"); + } for (int i=0; i< pipedOutStreams.length; i++) {