Skip to content

Commit d1cd0a0

Browse files
committed
Add missing .ConfigureAwait() + formatting mistake fixed
1 parent c6d512f commit d1cd0a0

File tree

5 files changed

+7
-7
lines changed

5 files changed

+7
-7
lines changed

Orm/Xtensive.Orm/Orm/Providers/CommandProcessing/SimpleCommandProcessor.cs

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -129,15 +129,15 @@ public override async Task<IEnumerator<Tuple>> ExecuteTasksWithReaderAsync(Query
129129

130130
token.ThrowIfCancellationRequested();
131131

132-
await ExecuteTasksAsync(context, token);
132+
await ExecuteTasksAsync(context, token).ConfigureAwait(false);
133133
context.AllowPartialExecution = oldValue;
134134

135135
var lastRequestCommand = Factory.CreateCommand();
136136
var commandPart = Factory.CreateQueryPart(lastRequest);
137137
ValidateCommandParameters(commandPart);
138138
lastRequestCommand.AddPart(commandPart);
139139
token.ThrowIfCancellationRequested();
140-
await lastRequestCommand.ExecuteReaderAsync(token);
140+
await lastRequestCommand.ExecuteReaderAsync(token).ConfigureAwait(false);
141141
return lastRequestCommand.AsReaderOf(lastRequest);
142142
}
143143

Orm/Xtensive.Orm/Orm/Providers/SqlIncludeProvider.cs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -69,7 +69,7 @@ protected override async Task OnBeforeEnumerateAsync(Rse.Providers.EnumerationCo
6969
// nothing
7070
break;
7171
case IncludeAlgorithm.TemporaryTable:
72-
await LockAndStoreAsync(context, filterDataSource.Invoke(), token);
72+
await LockAndStoreAsync(context, filterDataSource.Invoke(), token).ConfigureAwait(false);
7373
break;
7474
default:
7575
throw new ArgumentOutOfRangeException("Origin.Algorithm");

Orm/Xtensive.Orm/Orm/Providers/SqlSessionHandler.cs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -165,7 +165,7 @@ private void Prepare()
165165
private async Task PrepareAsync(CancellationToken cancellationToken)
166166
{
167167
Session.EnsureNotDisposed();
168-
await driver.EnsureConnectionIsOpenAsync(Session, connection, cancellationToken);
168+
await driver.EnsureConnectionIsOpenAsync(Session, connection, cancellationToken).ConfigureAwait(false);
169169

170170
try {
171171
foreach (var initializationSqlScript in initializationSqlScripts) {

Orm/Xtensive.Orm/Orm/Providers/SqlStoreProvider.cs

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -35,8 +35,8 @@ protected override void OnBeforeEnumerate(Rse.Providers.EnumerationContext conte
3535
/// <inheritdoc/>
3636
protected override async Task OnBeforeEnumerateAsync(Rse.Providers.EnumerationContext context, CancellationToken token)
3737
{
38-
await base.OnBeforeEnumerateAsync(context, token);
39-
await LockAndStoreAsync(context, Source, token);
38+
await base.OnBeforeEnumerateAsync(context, token).ConfigureAwait(false);
39+
await LockAndStoreAsync(context, Source, token).ConfigureAwait(false);
4040
}
4141

4242
protected override void OnAfterEnumerate(Rse.Providers.EnumerationContext context)

Orm/Xtensive.Orm/Orm/Rse/RecordSet.cs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -131,7 +131,7 @@ private async Task<IEnumerator<Tuple>> GetBatchedEnumeratorAsync(CancellationTok
131131
completableScope.Complete();
132132
completableScope.Dispose();
133133
};
134-
return GetTwoLevelEnumerator(batched, afterEnumerationAction, cs);
134+
return GetTwoLevelEnumerator(batched, afterEnumerationAction, cs);
135135
}
136136

137137
private static IEnumerator<Tuple> GetTwoLevelEnumerator(IEnumerable<IEnumerable<Tuple>> enumerable,

0 commit comments

Comments
 (0)