[Modify] Polish it
This commit is contained in:
parent
f518dd717c
commit
69c99b8765
@ -680,10 +680,8 @@ namespace WebSocketSharp
|
|||||||
|
|
||||||
Action<long> read = null;
|
Action<long> read = null;
|
||||||
read = len => {
|
read = len => {
|
||||||
if (len < bufferLength) {
|
if (len < bufferLength)
|
||||||
bufferLength = (int) len;
|
bufferLength = (int) len;
|
||||||
buff = new byte[bufferLength];
|
|
||||||
}
|
|
||||||
|
|
||||||
stream.readBytesAsync (
|
stream.readBytesAsync (
|
||||||
buff,
|
buff,
|
||||||
@ -694,7 +692,7 @@ namespace WebSocketSharp
|
|||||||
if (nread > 0)
|
if (nread > 0)
|
||||||
dest.Write (bytes, 0, nread);
|
dest.Write (bytes, 0, nread);
|
||||||
|
|
||||||
if (nread == 0 || (len -= nread) == 0) {
|
if (nread == 0 || nread == len) {
|
||||||
if (completed != null) {
|
if (completed != null) {
|
||||||
dest.Close ();
|
dest.Close ();
|
||||||
completed (dest.ToArray ());
|
completed (dest.ToArray ());
|
||||||
@ -704,7 +702,7 @@ namespace WebSocketSharp
|
|||||||
return;
|
return;
|
||||||
}
|
}
|
||||||
|
|
||||||
read (len);
|
read (len - nread);
|
||||||
},
|
},
|
||||||
ex => {
|
ex => {
|
||||||
dest.Dispose ();
|
dest.Dispose ();
|
||||||
|
Loading…
Reference in New Issue
Block a user