Skip to content
This repository was archived by the owner on Jul 30, 2025. It is now read-only.

Commit 821e16d

Browse files
committed
Continuation fixes
1 parent 716531f commit 821e16d

File tree

2 files changed

+6
-6
lines changed

2 files changed

+6
-6
lines changed

src/MediatR.CommandQuery/Queries/EntityContinuationQuery.cs

Lines changed: 6 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -7,16 +7,20 @@ namespace MediatR.CommandQuery.Queries;
77

88
public record EntityContinuationQuery<TReadModel> : CacheableQueryBase<EntityContinuationResult<TReadModel>>
99
{
10-
public EntityContinuationQuery(ClaimsPrincipal? principal, EntitySelect? query, string? continuationToken = null)
10+
public EntityContinuationQuery(ClaimsPrincipal? principal, EntitySelect? query, int pageSize = 10, string? continuationToken = null)
1111
: base(principal)
1212
{
1313
Query = query ?? new EntitySelect();
14+
PageSize = pageSize;
1415
ContinuationToken = continuationToken;
1516
}
1617

1718
[JsonPropertyName("query")]
1819
public EntitySelect Query { get; }
1920

21+
[JsonPropertyName("pageSize")]
22+
public int PageSize { get; }
23+
2024
[JsonPropertyName("continuationToken")]
2125
[JsonIgnore(Condition = JsonIgnoreCondition.WhenWritingNull)]
2226
public string? ContinuationToken { get; }
@@ -25,7 +29,7 @@ public override string GetCacheKey()
2529
=> CacheTagger.GetKey<TReadModel, int>
2630
(
2731
bucket: CacheTagger.Buckets.Continuation,
28-
value: HashCode.Combine(Query.GetHashCode(), ContinuationToken)
32+
value: HashCode.Combine(Query.GetHashCode(), PageSize, ContinuationToken)
2933
);
3034

3135
public override string? GetCacheTag()

src/MediatR.CommandQuery/Queries/EntityContinuationResult.cs

Lines changed: 0 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -4,10 +4,6 @@ namespace MediatR.CommandQuery.Queries;
44

55
public class EntityContinuationResult<TReadModel>
66
{
7-
[JsonPropertyName("previousToken")]
8-
[JsonIgnore(Condition = JsonIgnoreCondition.WhenWritingNull)]
9-
public string? PreviousToken { get; set; }
10-
117
[JsonPropertyName("continuationToken")]
128
[JsonIgnore(Condition = JsonIgnoreCondition.WhenWritingNull)]
139
public string? ContinuationToken { get; set; }

0 commit comments

Comments
 (0)