AggregateTracingHandlerFunction

class AggregateTracingHandlerFunction(aggregateMetadata: AggregateMetadata<*, *>, stateAggregateFactory: StateAggregateFactory, eventStore: EventStore, exceptionHandler: RequestExceptionHandler, tracingPolicy: TracingPolicy, admission: PointReadAdmission = PointReadAdmission.DISABLED) : HandlerFunction<ServerResponse>

Constructors

constructor(aggregateMetadata: AggregateMetadata<*, *>, stateAggregateFactory: StateAggregateFactory, eventStore: EventStore, exceptionHandler: RequestExceptionHandler, tracingPolicy: TracingPolicy, admission: PointReadAdmission = PointReadAdmission.DISABLED)

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

Resolves the range before the response starts, so a rejected range (the point-read admission cap) answers with its own status, then replays it.