Skip to content

Commit 1c6fa13

Browse files
committed
CS-1195: added in missing ConfigureAwaits.
1 parent 61d23c2 commit 1c6fa13

File tree

5 files changed

+7
-7
lines changed

5 files changed

+7
-7
lines changed

src/MongoDB.Driver.Core/BatchTransformingAsyncCursor.cs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -53,7 +53,7 @@ public IEnumerable<TToDocument> Current
5353
public async Task<bool> MoveNextAsync(CancellationToken cancellationToken)
5454
{
5555
ThrowIfDisposed();
56-
while (await _wrapped.MoveNextAsync(cancellationToken))
56+
while (await _wrapped.MoveNextAsync(cancellationToken).ConfigureAwait(false))
5757
{
5858
_current = _transformer(_wrapped.Current).ToList();
5959
if (_current.Count > 0)

src/MongoDB.Driver.Core/Core/ConnectionPools/ExclusiveConnectionPool.cs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -288,7 +288,7 @@ private async Task MaintainSize()
288288
{
289289
await PrunePoolAsync(maintenanceCancellationToken).ConfigureAwait(false);
290290
await EnsureMinSizeAsync(maintenanceCancellationToken).ConfigureAwait(false);
291-
await Task.Delay(_settings.MaintenanceInterval, maintenanceCancellationToken);
291+
await Task.Delay(_settings.MaintenanceInterval, maintenanceCancellationToken).ConfigureAwait(false);
292292
}
293293
catch
294294
{

src/MongoDB.Driver.Core/Core/Operations/DatabaseExistsOperation.cs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -74,7 +74,7 @@ public async Task<bool> ExecuteAsync(IReadBinding binding, CancellationToken can
7474
Ensure.IsNotNull(binding, "binding");
7575
var operation = new ListDatabasesOperation(_messageEncoderSettings);
7676
var result = await operation.ExecuteAsync(binding, cancellationToken).ConfigureAwait(false);
77-
var list = await result.ToListAsync();
77+
var list = await result.ToListAsync().ConfigureAwait(false);
7878
return list.Any(x => x["name"] == _databaseNamespace.DatabaseName);
7979
}
8080
}

src/MongoDB.Driver.Core/Core/Servers/ClusterableServer.cs

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -212,14 +212,14 @@ private async Task MonitorServer()
212212
{
213213
try
214214
{
215-
await HeartbeatAsync(heartbeatCancellationToken);
215+
await HeartbeatAsync(heartbeatCancellationToken).ConfigureAwait(false);
216216
var newHeartbeatDelay = new HeartbeatDelay(metronome.GetNextTickDelay(), __minHeartbeatInterval);
217217
var oldHeartbeatDelay = Interlocked.Exchange(ref _heartbeatDelay, newHeartbeatDelay);
218218
if (oldHeartbeatDelay != null)
219219
{
220220
oldHeartbeatDelay.Dispose();
221221
}
222-
await newHeartbeatDelay.Task;
222+
await newHeartbeatDelay.Task.ConfigureAwait(false);
223223
}
224224
catch
225225
{

src/MongoDB.Driver/MongoCollectionImpl.cs

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -338,7 +338,7 @@ public override Task<TProjection> FindOneAndUpdateAsync<TProjection>(FilterDefin
338338
Verbose = options.Verbose
339339
};
340340

341-
return await ExecuteReadOperation(operation, cancellationToken);
341+
return await ExecuteReadOperation(operation, cancellationToken).ConfigureAwait(false);
342342
}
343343
else
344344
{
@@ -368,7 +368,7 @@ public override Task<TProjection> FindOneAndUpdateAsync<TProjection>(FilterDefin
368368
Verbose = options.Verbose
369369
};
370370

371-
await ExecuteWriteOperation(operation, cancellationToken);
371+
await ExecuteWriteOperation(operation, cancellationToken).ConfigureAwait(false);
372372

373373
var findOperation = new FindOperation<TResult>(
374374
outputCollectionNamespace,

0 commit comments

Comments
 (0)