diff --git a/examples/Titanium.Web.Proxy.Examples.Wpf/Titanium.Web.Proxy.Examples.Wpf.csproj b/examples/Titanium.Web.Proxy.Examples.Wpf/Titanium.Web.Proxy.Examples.Wpf.csproj
index 12327d6e3..d9a1156b4 100644
--- a/examples/Titanium.Web.Proxy.Examples.Wpf/Titanium.Web.Proxy.Examples.Wpf.csproj
+++ b/examples/Titanium.Web.Proxy.Examples.Wpf/Titanium.Web.Proxy.Examples.Wpf.csproj
@@ -72,8 +72,8 @@
     <Prefer32Bit>true</Prefer32Bit>
   </PropertyGroup>
   <ItemGroup>
-    <Reference Include="StreamExtended, Version=1.0.179.0, Culture=neutral, PublicKeyToken=bbfa0f1d54f50043, processorArchitecture=MSIL">
-      <HintPath>..\..\packages\StreamExtended.1.0.179\lib\net45\StreamExtended.dll</HintPath>
+    <Reference Include="StreamExtended, Version=1.0.183.0, Culture=neutral, PublicKeyToken=bbfa0f1d54f50043, processorArchitecture=MSIL">
+      <HintPath>..\..\src\packages\StreamExtended.1.0.183-beta\lib\net45\StreamExtended.dll</HintPath>
     </Reference>
     <Reference Include="System" />
     <Reference Include="System.Data" />
diff --git a/examples/Titanium.Web.Proxy.Examples.Wpf/packages.config b/examples/Titanium.Web.Proxy.Examples.Wpf/packages.config
index f05fe4629..72c976674 100644
--- a/examples/Titanium.Web.Proxy.Examples.Wpf/packages.config
+++ b/examples/Titanium.Web.Proxy.Examples.Wpf/packages.config
@@ -1,4 +1,4 @@
 <?xml version="1.0" encoding="utf-8"?>
 <packages>
-  <package id="StreamExtended" version="1.0.179" targetFramework="net45" />
+  <package id="StreamExtended" version="1.0.183-beta" targetFramework="net45" />
 </packages>
\ No newline at end of file
diff --git a/src/Titanium.Web.Proxy/Helpers/TcpHelper.cs b/src/Titanium.Web.Proxy/Helpers/TcpHelper.cs
index 22e23c594..f321c2e24 100644
--- a/src/Titanium.Web.Proxy/Helpers/TcpHelper.cs
+++ b/src/Titanium.Web.Proxy/Helpers/TcpHelper.cs
@@ -93,112 +93,6 @@ private static uint toNetworkByteOrder(uint port)
             return ((port >> 8) & 0x00FF00FFu) | ((port << 8) & 0xFF00FF00u);
         }
 
-        /// <summary>
-        ///     relays the input clientStream to the server at the specified host name and port with the given httpCmd and headers
-        ///     as prefix
-        ///     Usefull for websocket requests
-        ///     Asynchronous Programming Model, which does not throw exceptions when the socket is closed
-        /// </summary>
-        /// <param name="clientStream"></param>
-        /// <param name="serverStream"></param>
-        /// <param name="bufferSize"></param>
-        /// <param name="onDataSend"></param>
-        /// <param name="onDataReceive"></param>
-        /// <param name="cancellationTokenSource"></param>
-        /// <param name="exceptionFunc"></param>
-        /// <returns></returns>
-        internal static async Task SendRawApm(Stream clientStream, Stream serverStream, 
-            IBufferPool bufferPool, int bufferSize,
-            Action<byte[], int, int> onDataSend, Action<byte[], int, int> onDataReceive,
-            CancellationTokenSource cancellationTokenSource,
-            ExceptionHandler exceptionFunc)
-        {
-            var taskCompletionSource = new TaskCompletionSource<bool>();
-            cancellationTokenSource.Token.Register(() => taskCompletionSource.TrySetResult(true));
-
-            // Now async relay all server=>client & client=>server data
-            var clientBuffer = bufferPool.GetBuffer(bufferSize);
-            var serverBuffer = bufferPool.GetBuffer(bufferSize);
-            try
-            {
-                beginRead(clientStream, serverStream, clientBuffer, onDataSend, cancellationTokenSource, exceptionFunc);
-                beginRead(serverStream, clientStream, serverBuffer, onDataReceive, cancellationTokenSource,
-                    exceptionFunc);
-                await taskCompletionSource.Task;
-            }
-            finally
-            {
-                bufferPool.ReturnBuffer(clientBuffer);
-                bufferPool.ReturnBuffer(serverBuffer);
-            }
-        }
-
-        private static void beginRead(Stream inputStream, Stream outputStream, byte[] buffer,
-            Action<byte[], int, int> onCopy, CancellationTokenSource cancellationTokenSource,
-            ExceptionHandler exceptionFunc)
-        {
-            if (cancellationTokenSource.IsCancellationRequested)
-            {
-                return;
-            }
-
-            bool readFlag = false;
-            var readCallback = (AsyncCallback)(ar =>
-            {
-                if (cancellationTokenSource.IsCancellationRequested || readFlag)
-                {
-                    return;
-                }
-
-                readFlag = true;
-
-                try
-                {
-                    int read = inputStream.EndRead(ar);
-                    if (read <= 0)
-                    {
-                        cancellationTokenSource.Cancel();
-                        return;
-                    }
-
-                    onCopy?.Invoke(buffer, 0, read);
-
-                    var writeCallback = (AsyncCallback)(ar2 =>
-                    {
-                        if (cancellationTokenSource.IsCancellationRequested)
-                        {
-                            return;
-                        }
-
-                        try
-                        {
-                            outputStream.EndWrite(ar2);
-                            beginRead(inputStream, outputStream, buffer, onCopy, cancellationTokenSource,
-                                exceptionFunc);
-                        }
-                        catch (IOException ex)
-                        {
-                            cancellationTokenSource.Cancel();
-                            exceptionFunc(ex);
-                        }
-                    });
-
-                    outputStream.BeginWrite(buffer, 0, read, writeCallback, null);
-                }
-                catch (IOException ex)
-                {
-                    cancellationTokenSource.Cancel();
-                    exceptionFunc(ex);
-                }
-            });
-
-            var readResult = inputStream.BeginRead(buffer, 0, buffer.Length, readCallback, null);
-            if (readResult.CompletedSynchronously)
-            {
-                readCallback(readResult);
-            }
-        }
-
         /// <summary>
         ///     relays the input clientStream to the server at the specified host name and port with the given httpCmd and headers
         ///     as prefix
diff --git a/src/Titanium.Web.Proxy/Titanium.Web.Proxy.csproj b/src/Titanium.Web.Proxy/Titanium.Web.Proxy.csproj
index 6f4ed48d0..b5d301479 100644
--- a/src/Titanium.Web.Proxy/Titanium.Web.Proxy.csproj
+++ b/src/Titanium.Web.Proxy/Titanium.Web.Proxy.csproj
@@ -14,8 +14,8 @@
 
   <ItemGroup>
     <PackageReference Include="BrotliSharpLib" Version="0.3.1" />
-    <PackageReference Include="Portable.BouncyCastle" Version="1.8.2" />
-    <PackageReference Include="StreamExtended" Version="1.0.179" />
+    <PackageReference Include="Portable.BouncyCastle" Version="1.8.3" />
+    <PackageReference Include="StreamExtended" Version="1.0.183-beta" />
   </ItemGroup>
 
   <ItemGroup Condition="'$(TargetFramework)' == 'netstandard2.0'">