@@ -72,7 +72,7 @@ public async Task WriteBatchCallsLogEventDataGeneratorGetColumnsAndValuesForEach
72
72
var logEvents = CreateLogEvents ( ) ;
73
73
74
74
// Act
75
- await _sut . WriteBatch ( logEvents , _dataTable ) . ConfigureAwait ( false ) ;
75
+ await _sut . WriteBatch ( logEvents , _dataTable ) ;
76
76
77
77
// Assert
78
78
_logEventDataGeneratorMock . Verify ( c => c . GetColumnsAndValues ( logEvents [ 0 ] ) , Times . Once ) ;
@@ -86,7 +86,7 @@ public async Task WriteBatchCallsSqlConnectionFactoryCreate()
86
86
var logEvents = CreateLogEvents ( ) ;
87
87
88
88
// Act
89
- await _sut . WriteBatch ( logEvents , _dataTable ) . ConfigureAwait ( false ) ;
89
+ await _sut . WriteBatch ( logEvents , _dataTable ) ;
90
90
91
91
// Assert
92
92
_sqlConnectionFactoryMock . Verify ( f => f . Create ( ) , Times . Once ) ;
@@ -99,7 +99,7 @@ public async Task WriteBatchCallsSqlConnectionWrapperOpenAsync()
99
99
var logEvents = CreateLogEvents ( ) ;
100
100
101
101
// Act
102
- await _sut . WriteBatch ( logEvents , _dataTable ) . ConfigureAwait ( false ) ;
102
+ await _sut . WriteBatch ( logEvents , _dataTable ) ;
103
103
104
104
// Assert
105
105
_sqlConnectionWrapperMock . Verify ( c => c . OpenAsync ( ) , Times . Once ) ;
@@ -113,7 +113,7 @@ public async Task WriteBatchCallsSqlConnectionWrappeCreateSqlBulkCopy()
113
113
var expectedDestinationTableName = string . Format ( CultureInfo . InvariantCulture , "[{0}].[{1}]" , _schemaName , _tableName ) ;
114
114
115
115
// Act
116
- await _sut . WriteBatch ( logEvents , _dataTable ) . ConfigureAwait ( false ) ;
116
+ await _sut . WriteBatch ( logEvents , _dataTable ) ;
117
117
118
118
// Assert
119
119
_sqlConnectionWrapperMock . Verify ( c => c . CreateSqlBulkCopy ( false , expectedDestinationTableName ) , Times . Once ) ;
@@ -128,7 +128,7 @@ public async Task WriteBatchCallsSqlConnectionWrappeCreateSqlBulkCopyWithDisable
128
128
var sut = new SqlBulkBatchWriter ( _tableName , _schemaName , true , _sqlConnectionFactoryMock . Object , _logEventDataGeneratorMock . Object ) ;
129
129
130
130
// Act
131
- await sut . WriteBatch ( logEvents , _dataTable ) . ConfigureAwait ( false ) ;
131
+ await sut . WriteBatch ( logEvents , _dataTable ) ;
132
132
133
133
// Assert
134
134
_sqlConnectionWrapperMock . Verify ( c => c . CreateSqlBulkCopy ( true , expectedDestinationTableName ) , Times . Once ) ;
@@ -145,7 +145,7 @@ public async Task WriteBatchCallsSqlBulkCopyWrapperAddSqlBulkCopyColumnMappingFo
145
145
_dataTable . Columns . Add ( new DataColumn ( column2Name ) ) ;
146
146
147
147
// Act
148
- await _sut . WriteBatch ( logEvents , _dataTable ) . ConfigureAwait ( false ) ;
148
+ await _sut . WriteBatch ( logEvents , _dataTable ) ;
149
149
150
150
// Assert
151
151
_sqlBulkCopyWrapper . Verify ( c => c . AddSqlBulkCopyColumnMapping ( column1Name , column1Name ) , Times . Once ) ;
@@ -159,7 +159,7 @@ public async Task WriteBatchCallsSqlBulkCopyWrapperWriteToServerAsync()
159
159
var logEvents = CreateLogEvents ( ) ;
160
160
161
161
// Act
162
- await _sut . WriteBatch ( logEvents , _dataTable ) . ConfigureAwait ( false ) ;
162
+ await _sut . WriteBatch ( logEvents , _dataTable ) ;
163
163
164
164
// Assert
165
165
_sqlBulkCopyWrapper . Verify ( c => c . WriteToServerAsync ( _dataTable ) , Times . Once ) ;
@@ -172,48 +172,48 @@ public async Task WriteBatchClearsDataTable()
172
172
var logEvents = CreateLogEvents ( ) ;
173
173
174
174
// Act
175
- await _sut . WriteBatch ( logEvents , _dataTable ) . ConfigureAwait ( false ) ;
175
+ await _sut . WriteBatch ( logEvents , _dataTable ) ;
176
176
177
177
// Assert
178
178
Assert . Empty ( _dataTable . Rows ) ;
179
179
}
180
180
181
181
[ Fact ]
182
- public void WriteBatchRethrowsIfLogEventDataGeneratorMockGetColumnsAndValuesThrows ( )
182
+ public async Task WriteBatchRethrowsIfLogEventDataGeneratorMockGetColumnsAndValuesThrows ( )
183
183
{
184
184
// Arrange
185
185
_logEventDataGeneratorMock . Setup ( d => d . GetColumnsAndValues ( It . IsAny < LogEvent > ( ) ) )
186
186
. Callback ( ( ) => throw new InvalidOperationException ( ) ) ;
187
187
var logEvents = CreateLogEvents ( ) ;
188
188
189
189
// Act + assert
190
- Assert . ThrowsAsync < InvalidOperationException > ( ( ) => _sut . WriteBatch ( logEvents , _dataTable ) ) ;
190
+ await Assert . ThrowsAsync < InvalidOperationException > ( ( ) => _sut . WriteBatch ( logEvents , _dataTable ) ) ;
191
191
}
192
192
193
193
[ Fact ]
194
- public void WriteBatchRethrowsIfSqlConnectionFactoryCreateThrows ( )
194
+ public async Task WriteBatchRethrowsIfSqlConnectionFactoryCreateThrows ( )
195
195
{
196
196
// Arrange
197
197
_sqlConnectionFactoryMock . Setup ( f => f . Create ( ) ) . Callback ( ( ) => throw new InvalidOperationException ( ) ) ;
198
198
var logEvents = CreateLogEvents ( ) ;
199
199
200
200
// Act + assert
201
- Assert . ThrowsAsync < InvalidOperationException > ( ( ) => _sut . WriteBatch ( logEvents , _dataTable ) ) ;
201
+ await Assert . ThrowsAsync < InvalidOperationException > ( ( ) => _sut . WriteBatch ( logEvents , _dataTable ) ) ;
202
202
}
203
203
204
204
[ Fact ]
205
- public void WriteBatchRethrowsIfSqlConnectionOpenAsyncThrows ( )
205
+ public async Task WriteBatchRethrowsIfSqlConnectionOpenAsyncThrows ( )
206
206
{
207
207
// Arrange
208
208
_sqlConnectionWrapperMock . Setup ( c => c . OpenAsync ( ) ) . Callback ( ( ) => throw new InvalidOperationException ( ) ) ;
209
209
var logEvents = CreateLogEvents ( ) ;
210
210
211
211
// Act + assert
212
- Assert . ThrowsAsync < InvalidOperationException > ( ( ) => _sut . WriteBatch ( logEvents , _dataTable ) ) ;
212
+ await Assert . ThrowsAsync < InvalidOperationException > ( ( ) => _sut . WriteBatch ( logEvents , _dataTable ) ) ;
213
213
}
214
214
215
215
[ Fact ]
216
- public void WriteBatchRethrowsIfSqlBulkCopyWriterAddSqlBulkCopyColumnMappingThrows ( )
216
+ public async Task WriteBatchRethrowsIfSqlBulkCopyWriterAddSqlBulkCopyColumnMappingThrows ( )
217
217
{
218
218
// Arrange
219
219
_sqlBulkCopyWrapper . Setup ( c => c . AddSqlBulkCopyColumnMapping ( It . IsAny < string > ( ) , It . IsAny < string > ( ) ) )
@@ -222,19 +222,19 @@ public void WriteBatchRethrowsIfSqlBulkCopyWriterAddSqlBulkCopyColumnMappingThro
222
222
_dataTable . Columns . Add ( new DataColumn ( "ColumnName" ) ) ;
223
223
224
224
// Act + assert
225
- Assert . ThrowsAsync < InvalidOperationException > ( ( ) => _sut . WriteBatch ( logEvents , _dataTable ) ) ;
225
+ await Assert . ThrowsAsync < InvalidOperationException > ( ( ) => _sut . WriteBatch ( logEvents , _dataTable ) ) ;
226
226
}
227
227
228
228
[ Fact ]
229
- public void WriteBatchRethrowsIfSqlBulkCopyWriterWriteToServerAsyncThrows ( )
229
+ public async Task WriteBatchRethrowsIfSqlBulkCopyWriterWriteToServerAsyncThrows ( )
230
230
{
231
231
// Arrange
232
232
_sqlBulkCopyWrapper . Setup ( c => c . WriteToServerAsync ( It . IsAny < DataTable > ( ) ) )
233
233
. Callback ( ( ) => throw new InvalidOperationException ( ) ) ;
234
234
var logEvents = CreateLogEvents ( ) ;
235
235
236
236
// Act + assert
237
- Assert . ThrowsAsync < InvalidOperationException > ( ( ) => _sut . WriteBatch ( logEvents , _dataTable ) ) ;
237
+ await Assert . ThrowsAsync < InvalidOperationException > ( ( ) => _sut . WriteBatch ( logEvents , _dataTable ) ) ;
238
238
}
239
239
240
240
private static List < LogEvent > CreateLogEvents ( )
0 commit comments