removed uned class

src/main/java/org/gcube/data/access/storagehub/MultipleOutputStream.java

@@ -1,144 +0,0 @@
-package org.gcube.data.access.storagehub;
-
-import java.io.BufferedInputStream;
-import java.io.IOException;
-import java.io.InputStream;
-import java.io.PipedInputStream;
-import java.io.PipedOutputStream;
-
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-
-public class MultipleOutputStream {
-
-	private Logger logger = LoggerFactory.getLogger(MultipleOutputStream.class);
-
-	private MyPipedInputStream[] pipedInStreams;
-
-	private InputStream is;
-
-	private MyPipedOututStream[] pipedOutStreams;
-
-	private int index=0;
-
-	public MultipleOutputStream(InputStream is, int number) throws IOException{
-		this.is = is;
-
-
-		logger.debug("UPLOAD: requested {} piped streams ",number);
-
-		pipedInStreams = new MyPipedInputStream[number];
-		pipedOutStreams = new MyPipedOututStream[number];
-
-		for (int i =0; i<number; i++) {		
-			pipedOutStreams[i] = new MyPipedOututStream();
-			pipedInStreams[i] = new MyPipedInputStream(pipedOutStreams[i]);
-		}
-
-	}
-
-	public void startWriting() throws IOException{
-		
-		logger.debug("UPLOAD: started writing multiple streams");
-		
-		BufferedInputStream bis = new BufferedInputStream(is);
-		byte[] buf = new byte[1024*32];
-		int read=-1;
-		long writeTot = 0;
-		while ((read =bis.read(buf))!=-1){
-			for (int i=0; i< pipedInStreams.length; i++) {
-				if (!pipedInStreams[i].isClosed()) {
-					pipedOutStreams[i].write(buf, 0, read);
-				}
-			}
-			
-			logger.trace("UPLOAD: read is {} and written total {}", read, writeTot);
-			
-			writeTot+= read;
-			if (allOutStreamClosed()) 
-				break;
-
-		}
-
-		for (int i=0; i< pipedOutStreams.length; i++) {
-			if (!pipedOutStreams[i].isClosed()) {
-				logger.debug("closing outputstream {}",i);
-				pipedOutStreams[i].close();
-			}
-		}
-
-		logger.debug("UPLOAD: total written {} ",writeTot);
-
-	}
-
-
-	private boolean allOutStreamClosed() {
-		for (int i=0; i<pipedOutStreams.length; i++) {
-			if (!pipedOutStreams[i].isClosed())
-				return false;
-		}
-		return true;
-	}
-
-	public synchronized InputStream get() {
-		logger.debug("requesting piped streams {}",index);
-		if (index>=pipedInStreams.length) return null;
-		return pipedInStreams[index++];
-	}
-
-
-	public class MyPipedOututStream extends PipedOutputStream{
-
-		boolean close = false;
-
-		@Override
-		public void close() throws IOException {
-			this.close = true;
-			super.close();
-		}
-
-		/**
-		 * @return the close
-		 */
-		public boolean isClosed() {
-			return close;
-		}
-
-		@Override
-		public void write(byte[] b, int off, int len) throws IOException {
-			try{
-				super.write(b, off, len);
-			}catch(IOException io){
-				this.close = true;
-			}
-		}
-
-
-
-
-	}
-
-	public class MyPipedInputStream extends PipedInputStream{
-
-		boolean close = false;
-
-		public MyPipedInputStream(PipedOutputStream src) throws IOException {
-			super(src);
-		}
-
-		@Override
-		public void close() throws IOException {
-			this.close = true;
-			logger.debug(Thread.currentThread().getName()+" close MyPipedInputStream");
-			super.close();
-		}
-
-		/**
-		 * @return the close
-		 */
-		public boolean isClosed() {
-			return close;
-		}
-
-	}
-}