gist.cs

using (var readTimeout = new CancellationTokenSource())
{
    readTimeout.CancelAfter(this.defaultTimeout); // not used so far

    currentSlice = AsyncContext.Run(
        () => connection.ReadStreamEventsForwardAsync(EventsPrefix + id.FormatGuid(), nextSliceStart, batchSize, false));
}