Using EF Core to stream data from database handling paging

CountryService.cs

public class CountryService
{
    private readonly IDbContextFactory<CountryDbContext> _contextFactory;

    public CountryService(IDbContextFactory<CountryDbContext> contextFactory)
        => _contextFactory = contextFactory;
    
    public async IAsyncEnumerable<Country> StreamCountries(
    int startAfterId = 0,
    [EnumeratorCancellation] CancellationToken ct = default)
    {
        var lastId = startAfterId;

        while (!ct.IsCancellationRequested)
        {
            await using var context = await _contextFactory.CreateDbContextAsync(ct);

             await foreach (var country in context.Countries
                .Where(c => c.Id > lastId)
                .OrderBy(c => c.Id)
                .AsAsyncEnumerable()
                .WithCancellation(ct))
                {
                    lastId = country.Id;
                    yield return country;
                }

            await Task.Delay(2000, ct);
        }
    }
}