INNER CODE UNIT · C#
take
Chinchilla-Software-Com/CQRS · Diagnostics/Cqrs.Diagnostics.EventStoreToEventBusReplay/Program.cs:297
int take = int.Parse(indexPart.Substring(rangeIndex + 1).Trim()) - skip;
selectedTypes.AddRange(allLocatedTypes.Skip(skip).Take(take));
}
}
return selectedTypes.ToArray();
}
/// <summary>
/// Scan the <see cref="IEventStore{TAuthenticationToken}">event store</see>
/// </summary>
protected virtual IEnumerable<IEvent<TAuthenticationToken>> LoadEventsFromEventStore(IEventPublisher<TAuthenticationToken> eventPublisher, IEventStore<TAuthenticationToken> eventStore, DateTime? fromDate = null, DateTime? toDate = null, params Type[] eventTypes)
{
bool resumeOnError;
if (!bool.TryParse(ConfigurationManager.AppSettings["ResumeOnError"], out resumeOnError))
resumeOnError = false;
var logger = DependencyResolver.Current.Resolve<ILogger>();