Table of Contents

Interface IContinuationReadRepository<TEntity>

Namespace
eQuantic.Core.Data.Repository.Read
Assembly
eQuantic.Core.Data.dll

A read repository that pages through its store's native continuation mechanism (Cassandra PagingState, Cosmos continuation tokens) instead of count-and-skip: every page costs the same, however deep, and the token is an opaque string a caller can hold across requests. Providers opt in.

public interface IContinuationReadRepository<TEntity> where TEntity : class

Type Parameters

TEntity

The entity type.

Methods

GetPageAsync(int, string?, QueryOptions<TEntity>?, CancellationToken)

Reads one page, resuming after continuationToken when supplied. The page size is the store's fetch hint — a page may hold fewer items (and client-evaluated residual filters reduce it further); the read is exhausted when the returned token is null.

Task<ContinuedResult<TEntity>> GetPageAsync(int pageSize, string? continuationToken = null, QueryOptions<TEntity>? options = null, CancellationToken cancellationToken = default)

Parameters

pageSize int

The page size hint (at least 1).

continuationToken string

The token from the previous page, or null for the first page.

options QueryOptions<TEntity>

Optional query shaping (filter, sorting).

cancellationToken CancellationToken

The cancellation token.

Returns

Task<ContinuedResult<TEntity>>

The page and the token resuming after it.