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 2021-02-04 19:40:29 +09:00
parent bcfc3c6863
commit c3927a4970
1 changed files with 5 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
websocket-sharp/Net/RequestStream.cs
View File

@ -173,13 +173,15 @@ namespace WebSocketSharp.Net
#region Public Methods #region Public Methods
public override IAsyncResult BeginRead ( public override IAsyncResult BeginRead (
byte[] buffer, int offset, int count, AsyncCallback callback, object state) byte[] buffer, int offset, int count, AsyncCallback callback, object state
)
{ {
if (_disposed) if (_disposed)
throw new ObjectDisposedException (GetType ().ToString ()); throw new ObjectDisposedException (GetType ().ToString ());
var nread = fillFromBuffer (buffer, offset, count); var nread = fillFromBuffer (buffer, offset, count);
if (nread > 0 || nread == -1) {
if (nread != 0) {
var ares = new HttpStreamAsyncResult (callback, state); var ares = new HttpStreamAsyncResult (callback, state);
ares.Buffer = buffer; ares.Buffer = buffer;
ares.Offset = offset; ares.Offset = offset;
@ -190,8 +192,7 @@ namespace WebSocketSharp.Net
return ares; return ares;
} }
// Avoid reading past the end of the request to allow for HTTP pipelining. if (_bodyLeft >= 0 && _bodyLeft < count)
if (_bodyLeft >= 0 && count > _bodyLeft)
count = (int) _bodyLeft; count = (int) _bodyLeft;
return _stream.BeginRead (buffer, offset, count, callback, state); return _stream.BeginRead (buffer, offset, count, callback, state);