@@ -173,12 +173,10 @@ public virtual async Task CreateAsync(TResource resourceFromRequest, TResource r
173
173
174
174
await _resourceDefinitionAccessor . OnWritingAsync ( resourceForDatabase , WriteOperationKind . CreateResource , cancellationToken ) ;
175
175
176
- await SaveChangesAsync ( ( ) =>
177
- {
178
- return _mongoDataAccess . ActiveSession != null
176
+ await SaveChangesAsync (
177
+ ( ) => _mongoDataAccess . ActiveSession != null
179
178
? Collection . InsertOneAsync ( _mongoDataAccess . ActiveSession , resourceForDatabase , cancellationToken : cancellationToken )
180
- : Collection . InsertOneAsync ( resourceForDatabase , cancellationToken : cancellationToken ) ;
181
- } , cancellationToken ) ;
179
+ : Collection . InsertOneAsync ( resourceForDatabase , cancellationToken : cancellationToken ) , cancellationToken ) ;
182
180
183
181
await _resourceDefinitionAccessor . OnWriteSucceededAsync ( resourceForDatabase , WriteOperationKind . CreateResource , cancellationToken ) ;
184
182
}
@@ -217,12 +215,10 @@ public virtual async Task UpdateAsync(TResource resourceFromRequest, TResource r
217
215
218
216
FilterDefinition < TResource > filter = Builders < TResource > . Filter . Eq ( resource => resource . Id , resourceFromDatabase . Id ) ;
219
217
220
- await SaveChangesAsync ( async ( ) =>
221
- {
222
- await ( _mongoDataAccess . ActiveSession != null
218
+ await SaveChangesAsync (
219
+ ( ) => _mongoDataAccess . ActiveSession != null
223
220
? Collection . ReplaceOneAsync ( _mongoDataAccess . ActiveSession , filter , resourceFromDatabase , cancellationToken : cancellationToken )
224
- : Collection . ReplaceOneAsync ( filter , resourceFromDatabase , cancellationToken : cancellationToken ) ) ;
225
- } , cancellationToken ) ;
221
+ : Collection . ReplaceOneAsync ( filter , resourceFromDatabase , cancellationToken : cancellationToken ) , cancellationToken ) ;
226
222
227
223
await _resourceDefinitionAccessor . OnWriteSucceededAsync ( resourceFromDatabase , WriteOperationKind . UpdateResource , cancellationToken ) ;
228
224
}
@@ -238,9 +234,9 @@ public virtual async Task DeleteAsync(TResource? resourceFromDatabase, TId id, C
238
234
FilterDefinition < TResource > filter = Builders < TResource > . Filter . Eq ( resource => resource . Id , id ) ;
239
235
240
236
DeleteResult result = await SaveChangesAsync (
241
- async ( ) => _mongoDataAccess . ActiveSession != null
242
- ? await Collection . DeleteOneAsync ( _mongoDataAccess . ActiveSession , filter , cancellationToken : cancellationToken )
243
- : await Collection . DeleteOneAsync ( filter , cancellationToken ) , cancellationToken ) ;
237
+ ( ) => _mongoDataAccess . ActiveSession != null
238
+ ? Collection . DeleteOneAsync ( _mongoDataAccess . ActiveSession , filter , cancellationToken : cancellationToken )
239
+ : Collection . DeleteOneAsync ( filter , cancellationToken ) , cancellationToken ) ;
244
240
245
241
if ( ! result . IsAcknowledged )
246
242
{
0 commit comments