Proposal: Place the loaded aggregate instance in a cache When getting a command for that instance, get it from the cache instead of loading it from the stream Check the stream revision If it's higher, read the stream tail It can be done in a composable version of the AggregateStore.