in DataGenerators/TwitterClientCore/EventDataGenerator.cs [57:66]
public void OnNext(string value)
{
this.tweetCount++;
this.streamWriter.WriteLine(value);
this.streamWriter.Flush();
if(this.waitIntervalStopWatch.Elapsed > this.maxTimeToBuffer || this.memoryStream.Length >= this.maxSizePerMessageInBytes)
{
this.SendEventData();
}
}