This commit is contained in:
Lucio Lelii 2018-07-12 13:43:44 +00:00
parent ec82e41948
commit 0636a22a7d
1 changed files with 2 additions and 4 deletions

View File

@ -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++) {