huahaofeng
/
aspnetcore
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

Remove dependency on new compiler (temporarily)

This commit is contained in:
David Fowler 2017-06-27 22:49:11 -07:00
parent ef0a46fcc4
commit ccf6cd415e
1 changed files with 3 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
src/Microsoft.AspNetCore.Sockets.Client.Http/ServerSentEventsMessageParser.cs
View File

@ -27,12 +27,11 @@ namespace Microsoft.AspNetCore.Sockets.Internal.Formatters
consumed = buffer.Start; consumed = buffer.Start;
examined = buffer.End; examined = buffer.End;
message = null; message = null;
var reader = new ReadableBufferReader(buffer);
var start = consumed; var start = consumed;
var end = examined; var end = examined;
while (!reader.End) while (buffer.Length > 0)
{ {
if (ReadCursorOperations.Seek(start, end, out var lineEnd, ByteLF) == -1) if (ReadCursorOperations.Seek(start, end, out var lineEnd, ByteLF) == -1)
{ {
@ -51,7 +50,7 @@ namespace Microsoft.AspNetCore.Sockets.Internal.Formatters
lineEnd = buffer.Move(lineEnd, 1); lineEnd = buffer.Move(lineEnd, 1);
var line = ConvertBufferToSpan(buffer.Slice(start, lineEnd)); var line = ConvertBufferToSpan(buffer.Slice(start, lineEnd));
reader.Skip(line.Length); buffer = buffer.Slice(line.Length);
if (line.Length <= 1) if (line.Length <= 1)
{ {
@ -138,7 +137,7 @@ namespace Microsoft.AspNetCore.Sockets.Internal.Formatters
return ParseResult.Completed; return ParseResult.Completed;
} }
if (reader.Peek() == ByteCR) if (buffer.Length > 0 && buffer.First.Span[0] == ByteCR)
{ {
_internalParserState = InternalParseState.ReadEndOfMessage; _internalParserState = InternalParseState.ReadEndOfMessage;
} }