Merge pull request #100 from justcoding121/release

enable Nagle algorithm

Author: justcoding121

Titanium.Web.Proxy/Network/TcpConnection.cs

@@ -44,6 +44,7 @@ internal TcpConnection()
 
         public void Dispose()
         {
+            Stream.Close();
             Stream.Dispose();
 
             TcpClient.LingerState = new LingerOption(true, 0);

Titanium.Web.Proxy/Network/TcpConnectionFactory.cs

@@ -119,8 +119,6 @@ internal async Task<TcpConnection> CreateClient(int bufferSize, int connectionTi
 
             stream.ReadTimeout = connectionTimeOutSeconds * 1000;
             stream.WriteTimeout = connectionTimeOutSeconds * 1000;
-
-            client.NoDelay = true;
 
             return new TcpConnection()
             {
@@ -133,7 +131,5 @@ internal async Task<TcpConnection> CreateClient(int bufferSize, int connectionTi
                 Version = httpVersion
             };
         }
-
-
     }
 }

Titanium.Web.Proxy/ProxyServer.cs

@@ -380,15 +380,11 @@ private void OnAcceptConnection(IAsyncResult asyn)
             }
 
             if (tcpClient != null)
-            {
-               
+            {               
                 Task.Run(async () =>
                 {
                     try
-                    {
-                        tcpClient.NoDelay = true;
-                        
-
+                    {      
                         if (endPoint.GetType() == typeof(TransparentProxyEndPoint))
                         {
                             await HandleClient(endPoint as TransparentProxyEndPoint, tcpClient);

Titanium.Web.Proxy/ResponseHandler.cs

@@ -7,6 +7,7 @@
 using System.Threading.Tasks;
 using Titanium.Web.Proxy.Extensions;
 using Titanium.Web.Proxy.Http;
+using Titanium.Web.Proxy.Helpers;
 
 namespace Titanium.Web.Proxy
 {
@@ -214,8 +215,8 @@ private void FixProxyHeaders(Dictionary<string, HttpHeader> headers)
         /// <param name="clientStreamReader"></param>
         /// <param name="clientStreamWriter"></param>
         /// <param name="args"></param>
-        private void Dispose(Stream clientStream, IDisposable clientStreamReader,
-            IDisposable clientStreamWriter, IDisposable args)
+        private void Dispose(Stream clientStream, CustomBinaryReader clientStreamReader,
+            StreamWriter clientStreamWriter, IDisposable args)
         {
 
             if (clientStream != null)
@@ -236,6 +237,7 @@ private void Dispose(Stream clientStream, IDisposable clientStreamReader,
 
             if (clientStreamWriter != null)
             {
+                clientStreamWriter.Close();
                 clientStreamWriter.Dispose();
             }
         }