DevWiki/websocket-sharp
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

[Modify] Polish it

Browse Source
This commit is contained in:
sta 2015-10-15 13:30:06 +09:00
parent d5b6bcfe88
commit f9eb4a8433
1 changed files with 7 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
websocket-sharp/Ext.cs
View File

@ -91,7 +91,7 @@ namespace WebSocketSharp
stream.Position = 0;
using (var ds = new DeflateStream (output, CompressionMode.Compress, true)) {
stream.CopyTo (ds);
stream.CopyTo (ds, 1024);
ds.Close (); // BFINAL set to 1.
output.Write (_last, 0, 1);
output.Position = 0;
@ -125,7 +125,7 @@ namespace WebSocketSharp
stream.Position = 0;
using (var ds = new DeflateStream (stream, CompressionMode.Decompress, true)) {
ds.CopyTo (output);
ds.CopyTo (output, 1024);
output.Position = 0;
return output;
@ -288,12 +288,11 @@ namespace WebSocketSharp
return dest;
}
internal static void CopyTo (this Stream source, Stream destination)
internal static void CopyTo (this Stream source, Stream destination, int bufferLength)
{
var buffLen = 1024;
var buff = new byte[buffLen];
var buff = new byte[bufferLength];
var nread = 0;
while ((nread = source.Read (buff, 0, buffLen)) > 0)
while ((nread = source.Read (buff, 0, bufferLength)) > 0)
destination.Write (buff, 0, nread);
}
@ -739,7 +738,7 @@ namespace WebSocketSharp
{
using (var output = new MemoryStream ()) {
stream.Position = 0;
stream.CopyTo (output);
stream.CopyTo (output, 1024);
output.Close ();
return output.ToArray ();
@ -898,7 +897,7 @@ namespace WebSocketSharp
internal static void WriteBytes (this Stream stream, byte[] bytes)
{
using (var input = new MemoryStream (bytes))
input.CopyTo (stream);
input.CopyTo (stream, 1024);
}
internal static void WriteBytes (this Stream stream, byte[] bytes, int length)