scanAggregateId
open override fun scanAggregateId(namedAggregate: NamedAggregate, afterId: String = FIRST_ID, limit: Int = 10): Flux<AggregateId>
Scans aggregate IDs from the in-memory map, filtered by named aggregate and afterId, then sorted and limited.
Return
a Flux of aggregate IDs
Parameters
namedAggregate
the named aggregate to scan
afterId
the ID to start scanning after
limit
the maximum number of IDs to return