EventStreamAggregationHandlerFunction

class EventStreamAggregationHandlerFunction(aggregateMetadata: AggregateMetadata<*, *>, queryGateway: EventStreamQueryGateway, queryRequestScope: QueryRequestScope, exceptionHandler: RequestExceptionHandler, guard: HttpQueryGuard = HttpQueryGuard()) : HandlerFunction<ServerResponse>

Constructors

constructor(aggregateMetadata: AggregateMetadata<*, *>, queryGateway: EventStreamQueryGateway, queryRequestScope: QueryRequestScope, exceptionHandler: RequestExceptionHandler, guard: HttpQueryGuard = HttpQueryGuard())

open override fun handle(request: ServerRequest): Mono<ServerResponse>