@@ -68,14 +68,13 @@ void IStoreEvents.Flush()
6868 private async Task BulkSubmitAsync ( IList < Event > events )
6969 {
7070 var cts = new CancellationTokenSource ( _config . HttpClientTimeout ) ;
71- StringContent stringContent = null ;
71+ var jsonEvents = "" ;
7272 try
7373 {
74- var json = JsonConvert . SerializeObject ( events . ToList ( ) , Formatting . None ) ;
75- stringContent = new StringContent ( json , Encoding . UTF8 , "application/json" ) ;
74+ jsonEvents = JsonConvert . SerializeObject ( events . ToList ( ) , Formatting . None ) ;
7675 Logger . LogDebug ( "Submitting " + events . Count + " events to " + _uri . AbsoluteUri + " with json: " +
77- stringContent ) ;
78- await SendEventsAsync ( stringContent , cts ) ;
76+ jsonEvents ) ;
77+ await SendEventsAsync ( jsonEvents , cts ) ;
7978 }
8079 catch ( Exception e )
8180 {
@@ -90,8 +89,8 @@ private async Task BulkSubmitAsync(IList<Event> events)
9089 try
9190 {
9291 Logger . LogDebug ( "Submitting " + events . Count + " events to " + _uri . AbsoluteUri + " with json: " +
93- stringContent ) ;
94- await SendEventsAsync ( stringContent , cts ) ;
92+ jsonEvents ) ;
93+ await SendEventsAsync ( jsonEvents , cts ) ;
9594 }
9695 catch ( TaskCanceledException tce )
9796 {
@@ -124,9 +123,10 @@ private async Task BulkSubmitAsync(IList<Event> events)
124123 }
125124
126125
127- private async Task SendEventsAsync ( StringContent content , CancellationTokenSource cts )
126+ private async Task SendEventsAsync ( String jsonEvents , CancellationTokenSource cts )
128127 {
129- using ( var response = await _httpClient . PostAsync ( _uri , content ) . ConfigureAwait ( false ) )
128+ using ( var stringContent = new StringContent ( jsonEvents , Encoding . UTF8 , "application/json" ) )
129+ using ( var response = await _httpClient . PostAsync ( _uri , stringContent ) . ConfigureAwait ( false ) )
130130 {
131131 if ( ! response . IsSuccessStatusCode )
132132 {
0 commit comments