diff -Naur ../../t2/commons-httpclient/src/java/org/apache/commons/httpclient/HttpConnection.java src/java/org/apache/commons/httpclient/HttpConnection.java --- ../../t2/commons-httpclient/src/java/org/apache/commons/httpclient/HttpConnection.java 2005-12-22 01:06:53.000000000 +1300 +++ src/java/org/apache/commons/httpclient/HttpConnection.java 2005-12-22 19:03:05.000000000 +1300 @@ -90,6 +90,10 @@ * @version $Revision$ $Date: 2005-10-23 06:34:28 -0700 (Sun, 23 Oct 2005) $ */ public class HttpConnection { + public interface IOWrapper { + InputStream wrapInput(InputStream is); + OutputStream wrapOutput(OutputStream os); + } // ----------------------------------------------------------- Constructors @@ -743,6 +747,12 @@ } inputStream = new BufferedInputStream(socket.getInputStream(), inbuffersize); outputStream = new BufferedOutputStream(socket.getOutputStream(), outbuffersize); + IOWrapper ioWrapper = (IOWrapper)this.params.getParameter("iowrapper"); + if(ioWrapper!=null) { + inputStream = ioWrapper.wrapInput(inputStream); + outputStream = ioWrapper.wrapOutput(outputStream); + } + isOpen = true; } catch (IOException e) { // Connection wasn't opened properly @@ -801,6 +811,12 @@ } inputStream = new BufferedInputStream(socket.getInputStream(), inbuffersize); outputStream = new BufferedOutputStream(socket.getOutputStream(), outbuffersize); + IOWrapper ioWrapper = (IOWrapper)this.params.getParameter("iowrapper"); + if(ioWrapper!=null) { + inputStream = ioWrapper.wrapInput(inputStream); + outputStream = ioWrapper.wrapOutput(outputStream); + } + usingSecureSocket = true; tunnelEstablished = true; }