JsonQuerySchemaSource
constructor(typeResolver: (QuerySchemaContext) -> Class<*> = { context ->
val aggregateType = context.namedAggregate.requiredAggregateType<Any>()
if (context.model == QueryModel.EVENT_STREAM) {
aggregateType
} else {
aggregateType.aggregateMetadata<Any, Any>().state.aggregateType
}
}, declarationResolver: (QueryModel, Class<*>) -> QuerySchemaDeclaration = ::inferDeclaration)