in DataGenerators/TwitterClientCore/EventDataGenerator.cs [68:91]
private void SendEventData(bool isCompleted = false)
{
if(this.memoryStream.Length == 0)
{
return;
}
this.messagesCount++;
this.gzipStream.Close();
var eventData = new EventData(this.memoryStream.ToArray());
this.eventDataOutputObserver.OnNext(eventData);
this.gzipStream.Dispose();
this.memoryStream.Dispose();
if(!isCompleted)
{
this.memoryStream = new MemoryStream(this.maxSizePerMessageInBytes);
this.gzipStream = new GZipStream(this.memoryStream, CompressionMode.Compress);
this.streamWriter = new StreamWriter(this.gzipStream);
}
Console.WriteLine($"Time: {DateTime.UtcNow:o} Sent TweetCount = {this.tweetCount} MessageCount = {this.messagesCount}");
this.waitIntervalStopWatch.Restart();
}