diff --git a/framework/src/Volo.Abp.Uow/Volo/Abp/Uow/UnitOfWork.cs b/framework/src/Volo.Abp.Uow/Volo/Abp/Uow/UnitOfWork.cs index 3212bf52a4..25135a0b9b 100644 --- a/framework/src/Volo.Abp.Uow/Volo/Abp/Uow/UnitOfWork.cs +++ b/framework/src/Volo.Abp.Uow/Volo/Abp/Uow/UnitOfWork.cs @@ -139,8 +139,8 @@ public class UnitOfWork : IUnitOfWork, ITransientDependency _isCompleting = true; await SaveChangesAsync(cancellationToken); - DistributedEvents.AddRange(GetEventsRecordsByPredicate(DistributedEventWithPredicates)); - LocalEvents.AddRange(GetEventsRecordsByPredicate(LocalEventWithPredicates)); + DistributedEvents.AddRange(GetEventsRecords(DistributedEventWithPredicates)); + LocalEvents.AddRange(GetEventsRecords(LocalEventWithPredicates)); while (LocalEvents.Any() || DistributedEvents.Any()) { @@ -152,7 +152,7 @@ public class UnitOfWork : IUnitOfWork, ITransientDependency await UnitOfWorkEventPublisher.PublishLocalEventsAsync( localEventsToBePublished ); - LocalEvents.AddRange(GetEventsRecordsByPredicate(LocalEventWithPredicates)); + LocalEvents.AddRange(GetEventsRecords(LocalEventWithPredicates)); } if (DistributedEvents.Any()) @@ -163,7 +163,7 @@ public class UnitOfWork : IUnitOfWork, ITransientDependency await UnitOfWorkEventPublisher.PublishDistributedEventsAsync( distributedEventsToBePublished ); - DistributedEvents.AddRange(GetEventsRecordsByPredicate(DistributedEventWithPredicates)); + DistributedEvents.AddRange(GetEventsRecords(DistributedEventWithPredicates)); } await SaveChangesAsync(cancellationToken); @@ -265,7 +265,7 @@ public class UnitOfWork : IUnitOfWork, ITransientDependency DistributedEventWithPredicates.Add(new KeyValuePair?>(eventRecord, replacementSelector)); } - protected virtual List GetEventsRecordsByPredicate(List?>> eventWithPredicates) + protected virtual List GetEventsRecords(List?>> eventWithPredicates) { var eventRecords = new List(); foreach (var eventWithPredicate in eventWithPredicates)