INNER CODE UNIT · C#
limitCount
Chinchilla-Software-Com/CQRS · Diagnostics/Cqrs.Diagnostics.EventStoreToEventBusReplay/Program.cs:378
limitCount = limitCount + subResults.Count;
runQuery = query.Take(limitCount).Skip(skipCount);
} while (true);
return results;
}
SqlEventStore<TAuthenticationToken> sqlEventStore = eventStore as SqlEventStore<TAuthenticationToken>;
if (sqlEventStore != null)
{
IQueryable<EventData> query = new ExposedSqlEventStore(sqlEventStore).RawQuery
.OrderBy(eventData => eventData.Timestamp);
return LoadEventsFromEventStore(eventPublisher, query, fromDate, toDate, eventTypes);
}
throw new NotImplementedException();
}