@@ -84,24 +84,24 @@ public override async Task<bool> SendBatchAsync(ArraySegment<byte> symbols)
84
84
85
85
MultipartFormItem symbolsItem ;
86
86
87
- if ( _enableCompression )
87
+ if ( ! this . _enableCompression )
88
+ {
89
+ symbolsItem = new MultipartFormItem ( "file" , MimeTypes . Json , "file.json" , symbols ) ;
90
+ }
91
+ else
88
92
{
89
93
using var memoryStream = new MemoryStream ( ) ;
90
94
#if NETFRAMEWORK
91
- using var gzipStream = new Vendors . ICSharpCode . SharpZipLib . GZip . GZipOutputStream ( memoryStream ) ;
92
- await gzipStream . WriteAsync ( symbols . Array , 0 , symbols . Array . Length ) . ConfigureAwait ( false ) ;
93
- await gzipStream . FlushAsync ( ) . ConfigureAwait ( false ) ;
95
+ using ( var gzipStream = new Vendors . ICSharpCode . SharpZipLib . GZip . GZipOutputStream ( memoryStream ) )
94
96
#else
95
- using var gzipStream = new GZipStream ( memoryStream , CompressionMode . Compress ) ;
96
- await gzipStream . WriteAsync ( symbols . Array , 0 , symbols . Array . Length ) . ConfigureAwait ( false ) ;
97
- await gzipStream . FlushAsync ( ) . ConfigureAwait ( false ) ;
97
+ using ( var gzipStream = new GZipStream ( memoryStream , CompressionMode . Compress ) )
98
98
#endif
99
+ {
100
+ await gzipStream . WriteAsync ( symbols . Array , 0 , symbols . Array . Length ) . ConfigureAwait ( false ) ;
101
+ }
102
+
99
103
symbolsItem = new MultipartFormItem ( "file" , MimeTypes . Gzip , "file.gz" , new ArraySegment < byte > ( memoryStream . ToArray ( ) ) ) ;
100
104
}
101
- else
102
- {
103
- symbolsItem = new MultipartFormItem ( "file" , MimeTypes . Json , "file.json" , symbols ) ;
104
- }
105
105
106
106
var items = new [ ] { symbolsItem , new MultipartFormItem ( "event" , MimeTypes . Json , "event.json" , _eventMetadata ) } ;
107
107
0 commit comments