wow-webflux/me.ahoo.wow.webflux.route

Package-level declarations

Types

AggregateRouteHandlerFunctionFactorySupport

abstract class AggregateRouteHandlerFunctionFactorySupport(val handlerKey: String) : HttpRouteHandlerFunctionFactory

CommandRouteHandlerFunctionFactorySupport

abstract class CommandRouteHandlerFunctionFactorySupport(val handlerKey: String) : HttpRouteHandlerFunctionFactory

HttpRouteHandlerFunctionFactory

interface HttpRouteHandlerFunctionFactory

NoMetadataRouteHandlerFunctionFactorySupport

abstract class NoMetadataRouteHandlerFunctionFactorySupport(val handlerKey: String) : HttpRouteHandlerFunctionFactory

RouteHandlerFunctionRegistrar

class RouteHandlerFunctionRegistrar(httpFactories: Collection<HttpRouteHandlerFunctionFactory> = emptyList())

RouteIdentityHandlerFunction

@InternalWowApi

class RouteIdentityHandlerFunction(val delegate: HandlerFunction<ServerResponse>, routeIdentity: RouteIdentity) : HandlerFunction<ServerResponse>

delegate, given the identity binding of its route on every request.

RouterFunctionBuilder

class RouterFunctionBuilder(routerSpecs: RouterSpecs, routeHandlerFunctionRegistrar: RouteHandlerFunctionRegistrar, identityHeaderAliases: IdentityHeaderAliases = IdentityHeaderAliases.NONE)

org.springframework.web.reactive.function.server.support.RouterFunctionMapping

StringServerSentEventType

object StringServerSentEventType : ParameterizedTypeReference<ServerSentEvent<String>>

Functions

errorResume

fun Flux<ServerSentEvent<String>>.errorResume(request: ServerRequest, exceptionHandler: RequestExceptionHandler): Flux<ServerSentEvent<String>>

getRawRequest

fun ContextView.getRawRequest(): ServerRequest?

mapRequestBodyDecodingException

@InternalWowApi

fun <T : Any> Mono<T>.mapRequestBodyDecodingException(): Mono<T>

Maps a failure to read the request body as the route's type to 400 (ServerWebInputException).

preferredResponseMediaType

@InternalWowApi

fun ServerRequest.preferredResponseMediaType(supportedMediaTypes: List<MediaType>): MediaType

toBatchResult

fun Flux<AggregateId>.toBatchResult(afterId: String, request: ServerRequest, exceptionHandler: RequestExceptionHandler): Mono<BatchResult>

The batch's result: the highest id processed and how many, or, when the batch fails, its error mapped and logged by RequestExceptionHandler.handleInBody, like every other error of request.

toEventStreamResponse

fun Flux<ServerSentEvent<String>>.toEventStreamResponse(request: ServerRequest, exceptionHandler: RequestExceptionHandler): Mono<ServerResponse>

toServerResponse

fun <T : Any> Flux<T>.toServerResponse(request: ServerRequest, exceptionHandler: RequestExceptionHandler): Mono<ServerResponse>

fun Mono<*>.toServerResponse(request: ServerRequest, exceptionHandler: RequestExceptionHandler): Mono<ServerResponse>

writeRawRequest

fun <T : Any> Flux<T>.writeRawRequest(request: ServerRequest): Flux<T>

fun <T : Any> Mono<T>.writeRawRequest(request: ServerRequest): Mono<T>