public void OnNext()

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