scanAggregateId

abstract fun scanAggregateId(namedAggregate: NamedAggregate, afterId: String = FIRST_ID, limit: Int = 10): Flux<AggregateId>

Scans for aggregate IDs within the specified named aggregate, starting after the given ID. Returns a limited number of aggregate IDs in lexicographical order.

Return

a Flux of aggregate IDs

Parameters

namedAggregate

the named aggregate to scan within

afterId

the ID to start scanning after (default: FIRST_ID)

limit

the maximum number of aggregate IDs to return (default: 10)