Repository: cxf Updated Branches: refs/heads/master 78d5199f0 -> cf4cb4b82
The cached output stuff has never been used for pipes, remove the code. Project: http://git-wip-us.apache.org/repos/asf/cxf/repo Commit: http://git-wip-us.apache.org/repos/asf/cxf/commit/cf4cb4b8 Tree: http://git-wip-us.apache.org/repos/asf/cxf/tree/cf4cb4b8 Diff: http://git-wip-us.apache.org/repos/asf/cxf/diff/cf4cb4b8 Branch: refs/heads/master Commit: cf4cb4b82ee2acc80422a517a1afbd8f48b9d571 Parents: 78d5199 Author: Daniel Kulp <[email protected]> Authored: Wed Mar 26 12:58:32 2014 -0400 Committer: Daniel Kulp <[email protected]> Committed: Wed Mar 26 12:58:58 2014 -0400 ---------------------------------------------------------------------- .../java/org/apache/cxf/io/CachedOutputStream.java | 13 ------------- 1 file changed, 13 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/cxf/blob/cf4cb4b8/core/src/main/java/org/apache/cxf/io/CachedOutputStream.java ---------------------------------------------------------------------- diff --git a/core/src/main/java/org/apache/cxf/io/CachedOutputStream.java b/core/src/main/java/org/apache/cxf/io/CachedOutputStream.java index 2cca6af..441ea83 100644 --- a/core/src/main/java/org/apache/cxf/io/CachedOutputStream.java +++ b/core/src/main/java/org/apache/cxf/io/CachedOutputStream.java @@ -30,8 +30,6 @@ import java.io.IOException; import java.io.InputStream; import java.io.InputStreamReader; import java.io.OutputStream; -import java.io.PipedInputStream; -import java.io.PipedOutputStream; import java.io.Reader; import java.security.GeneralSecurityException; import java.util.ArrayList; @@ -93,12 +91,6 @@ public class CachedOutputStream extends OutputStream { private List<Object> streamList = new ArrayList<Object>(); - public CachedOutputStream(PipedInputStream stream) throws IOException { - currentStream = new PipedOutputStream(stream); - inmem = true; - readBusProperties(); - } - public CachedOutputStream() { this(defaultThreshold); } @@ -260,9 +252,6 @@ public class CachedOutputStream extends OutputStream { if (copyOldContent && byteOut.size() > 0) { byteOut.writeTo(out); } - } else if (currentStream instanceof PipedOutputStream) { - PipedOutputStream pipeOut = (PipedOutputStream) currentStream; - IOUtils.copyAndCloseInput(new PipedInputStream(pipeOut), out); } else { throw new IOException("Unknown format of currentStream"); } @@ -520,8 +509,6 @@ public class CachedOutputStream extends OutputStream { return ((LoadingByteArrayOutputStream) currentStream).createInputStream(); } else if (currentStream instanceof ByteArrayOutputStream) { return new ByteArrayInputStream(((ByteArrayOutputStream) currentStream).toByteArray()); - } else if (currentStream instanceof PipedOutputStream) { - return new PipedInputStream((PipedOutputStream) currentStream); } else { return null; }
