Skip to content

Commit db584d7

Browse files
committed
Addressing a couple bits of PR comments
1 parent 453197e commit db584d7

File tree

2 files changed

+7
-6
lines changed

2 files changed

+7
-6
lines changed

src/Microsoft.Data.SqlClient/src/Microsoft/Data/SqlClient/SqlBulkCopy.cs

Lines changed: 6 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -2366,17 +2366,18 @@ private void CopyColumnsAsyncSetupContinuation(TaskCompletionSource<object> sour
23662366
AsyncHelper.ContinueTaskWithState(
23672367
taskToContinue: task,
23682368
taskCompletionSource: source,
2369-
state: this,
2370-
onSuccess: this2 =>
2369+
state1: this,
2370+
state2: Tuple.Create(source, i),
2371+
onSuccess: static (this2, parameters) =>
23712372
{
2372-
if (i + 1 < this2._sortedColumnMappings.Count)
2373+
if (parameters.Item2 + 1 < this2._sortedColumnMappings.Count)
23732374
{
23742375
// continue from the next column
2375-
this2.CopyColumnsAsync(i + 1, source);
2376+
this2.CopyColumnsAsync(parameters.Item2 + 1, parameters.Item1);
23762377
}
23772378
else
23782379
{
2379-
source.SetResult(null);
2380+
parameters.Item1.SetResult(null);
23802381
}
23812382
});
23822383
}

src/Microsoft.Data.SqlClient/src/Microsoft/Data/SqlClient/SqlCommand.Reader.cs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1591,7 +1591,7 @@ private Task RunExecuteReaderTdsSetupContinuation(
15911591
this2._activeConnection.GetOpenTdsConnection();
15921592
this2.CachedAsyncState.SetAsyncReaderState(parameters.Item1, parameters.Item2, parameters.Item3);
15931593
},
1594-
onFailure: static (this2, _, exception) =>
1594+
onFailure: static (this2, _, _) =>
15951595
this2._activeConnection.GetOpenTdsConnection().DecrementAsyncCount());
15961596
}
15971597

0 commit comments

Comments
 (0)