rehydrate.cs

public BankAccountGrain()
{
    var settings = ConnectionSettings
        .Create()
        .EnableVerboseLogging()
        .UseConsoleLogger();

    _conn = EventStoreConnection.Create(settings, new IPEndPoint(IPAddress.Loopback, Defaultport));
}

public override async Task OnActivateAsync()
{
    _stream = $"{GetType().Name}-{this.GetPrimaryKey()}";

    await _conn.ConnectAsync();

    StreamEventsSlice currentSlice;
    var nextSliceStart = StreamPosition.Start;
    do
    {
        currentSlice = await _conn.ReadStreamEventsForwardAsync(_stream, nextSliceStart, 200, false);
        foreach (var evnt in currentSlice.Events)
        {
            base.RaiseEvent(DeserializeEvent(evnt.Event));
        }

        nextSliceStart = (int)currentSlice.NextEventNumber;

    } while (!currentSlice.IsEndOfStream);

    await ConfirmEvents();
}