private void SendEventData()

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();
        }