From fef4747e265274d147e9b5e1ba9d1ac484e8abfd Mon Sep 17 00:00:00 2001
From: sta <sta.blockhead@gmail.com>
Date: Thu, 15 Oct 2015 15:40:15 +0900
Subject: [PATCH] [Modify] Add an extension method

---
 websocket-sharp/Ext.cs | 31 +++++++++++++++++++++++++++++++
 1 file changed, 31 insertions(+)

diff --git a/websocket-sharp/Ext.cs b/websocket-sharp/Ext.cs
index fc67621c..f0ec2d8d 100644
--- a/websocket-sharp/Ext.cs
+++ b/websocket-sharp/Ext.cs
@@ -905,6 +905,37 @@ namespace WebSocketSharp
       stream.Write (bytes, 0, length);
     }
 
+    internal static void WriteBytesAsync (
+      this Stream stream, byte[] bytes, int bufferLength, Action completed, Action<Exception> error)
+    {
+      var input = new MemoryStream (bytes);
+      var buff = new byte[bufferLength];
+
+      AsyncCallback callback = null;
+      callback = ar => {
+        try {
+          var nread = input.EndRead (ar);
+          if (nread <= 0) {
+            if (completed != null)
+              completed ();
+
+            input.Dispose ();
+            return;
+          }
+
+          stream.Write (buff, 0, nread);
+          input.BeginRead (buff, 0, bufferLength, callback, null);
+        }
+        catch (Exception ex) {
+          input.Dispose ();
+          if (error != null)
+            error (ex);
+        }
+      };
+
+      input.BeginRead (buff, 0, bufferLength, callback, null);
+    }
+
     #endregion
 
     #region Public Methods