resolve

abstract suspend fun resolve(subscription: SubscriptionId, ref: AggregateRef, partition: Int): ParkedAggregate?

Resolves the entry parking ref for subscription, as resolveAnywhere does, while the aggregate is parked in partition: the worker of that partition resolves it after its retry handled every parked stream it read there, or as an operator's skip. An entry re-homed to another partition meanwhile (repark) stays: its streams there are that partition's worker's.

Return

the removed entry, or null when the aggregate is not parked in partition.