[Modify] Polish it
This commit is contained in:
parent
7bc9039350
commit
345e7decb1
@ -834,17 +834,26 @@ namespace WebSocketSharp
|
|||||||
ar => {
|
ar => {
|
||||||
try {
|
try {
|
||||||
var nread = stream.EndRead (ar);
|
var nread = stream.EndRead (ar);
|
||||||
if (nread > 0)
|
if (nread <= 0) {
|
||||||
dest.Write (buff, 0, nread);
|
if (retry < _retry) {
|
||||||
|
retry++;
|
||||||
|
read (len);
|
||||||
|
|
||||||
if (nread == 0 && retry < _retry) {
|
return;
|
||||||
retry++;
|
}
|
||||||
read (len);
|
|
||||||
|
|
||||||
|
if (completed != null) {
|
||||||
|
dest.Close ();
|
||||||
|
completed (dest.ToArray ());
|
||||||
|
}
|
||||||
|
|
||||||
|
dest.Dispose ();
|
||||||
return;
|
return;
|
||||||
}
|
}
|
||||||
|
|
||||||
if (nread == 0 || nread == len) {
|
dest.Write (buff, 0, nread);
|
||||||
|
|
||||||
|
if (nread == len) {
|
||||||
if (completed != null) {
|
if (completed != null) {
|
||||||
dest.Close ();
|
dest.Close ();
|
||||||
completed (dest.ToArray ());
|
completed (dest.ToArray ());
|
||||||
@ -855,6 +864,7 @@ namespace WebSocketSharp
|
|||||||
}
|
}
|
||||||
|
|
||||||
retry = 0;
|
retry = 0;
|
||||||
|
|
||||||
read (len - nread);
|
read (len - nread);
|
||||||
}
|
}
|
||||||
catch (Exception ex) {
|
catch (Exception ex) {
|
||||||
|
Loading…
Reference in New Issue
Block a user