Skip to content

Commit 1d7cb40

Browse files
committed
fixup! Implement universal query batch
Converted event to delegate property
1 parent a6f5fe7 commit 1d7cb40

File tree

4 files changed

+7
-7
lines changed

4 files changed

+7
-7
lines changed

src/NHibernate/Async/Multi/QueryBatchItemBase.cs

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -73,14 +73,14 @@ public async Task ProcessResultsAsync(CancellationToken cancellationToken)
7373
await (queryInfo.Loader.PutResultInQueryCacheAsync(Session, queryInfo.Parameters, queryInfo.Cache, queryInfo.CacheKey, _loaderResults[i], cancellationToken)).ConfigureAwait(false);
7474
}
7575
}
76-
OnAfterLoad?.Invoke(GetResults());
76+
AfterLoadCallback?.Invoke(GetResults());
7777
}
7878

7979
public async Task ExecuteNonBatchedAsync(CancellationToken cancellationToken)
8080
{
8181
cancellationToken.ThrowIfCancellationRequested();
8282
_finalResults = await (GetResultsNonBatchedAsync(cancellationToken)).ConfigureAwait(false);
83-
OnAfterLoad?.Invoke(_finalResults);
83+
AfterLoadCallback?.Invoke(_finalResults);
8484
}
8585

8686
protected abstract Task<IList<TResult>> GetResultsNonBatchedAsync(CancellationToken cancellationToken);

src/NHibernate/Multi/IQueryBatchItem.cs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -21,7 +21,7 @@ public interface IQueryBatchItem<TResult> : IQueryBatchItem
2121
/// Callback is executed after results are loaded by batch.
2222
/// Loaded results are provided in action parameter.
2323
/// </summary>
24-
event Action<IList<TResult>> OnAfterLoad;
24+
Action<IList<TResult>> AfterLoadCallback { get; set; }
2525
}
2626

2727
/// <summary>

src/NHibernate/Multi/QueryBatchExtensions.cs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -359,7 +359,7 @@ private static IQueryBatch Add<TResult>(this IQueryBatch batch, IQueryBatchItem<
359359
{
360360
if (afterLoad != null)
361361
{
362-
query.OnAfterLoad += afterLoad;
362+
query.AfterLoadCallback += afterLoad;
363363
}
364364
batch.Add(query);
365365
return batch;

src/NHibernate/Multi/QueryBatchItemBase.cs

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -174,13 +174,13 @@ public void ProcessResults()
174174
queryInfo.Loader.PutResultInQueryCache(Session, queryInfo.Parameters, queryInfo.Cache, queryInfo.CacheKey, _loaderResults[i]);
175175
}
176176
}
177-
OnAfterLoad?.Invoke(GetResults());
177+
AfterLoadCallback?.Invoke(GetResults());
178178
}
179179

180180
public void ExecuteNonBatched()
181181
{
182182
_finalResults = GetResultsNonBatched();
183-
OnAfterLoad?.Invoke(_finalResults);
183+
AfterLoadCallback?.Invoke(_finalResults);
184184
}
185185

186186
public IEnumerable<string> GetQuerySpaces()
@@ -213,7 +213,7 @@ public IList<TResult> GetResults()
213213
return _finalResults ?? (_finalResults = DoGetResults());
214214
}
215215

216-
public event Action<IList<TResult>> OnAfterLoad;
216+
public Action<IList<TResult>> AfterLoadCallback { get; set; }
217217

218218
protected abstract List<TResult> DoGetResults();
219219

0 commit comments

Comments
 (0)