in Darabonba/Utils/StreamUtils.cs [235:259]
public static IEnumerable<SSEEvent> ReadAsSSE(Stream stream)
{
using (var reader = new StreamReader(stream))
{
var buffer = new char[4096];
var rest = string.Empty;
int count;
while ((count = reader.Read(buffer, 0, buffer.Length)) > 0)
{
var chunk = new string(buffer, 0, count);
var eventResult = TryGetEvents(rest, chunk);
rest = eventResult.Remain;
if (eventResult.Events != null && eventResult.Events.Count > 0)
{
foreach (var @event in eventResult.Events)
{
yield return @event;
}
}
}
}
}