public class RequestProcessor extends Object
Modifier and Type | Class and Description |
---|---|
static class |
RequestProcessor.FunctionWrapper
Wrapper for functions.
|
Constructor and Description |
---|
RequestProcessor(FunctionInspector inspector,
FunctionCatalog functionCatalog,
org.springframework.beans.factory.ObjectProvider<JsonMapper> mapper,
StringConverter converter,
org.springframework.beans.factory.ObjectProvider<org.springframework.http.codec.ServerCodecConfigurer> codecs) |
Modifier and Type | Method and Description |
---|---|
reactor.core.publisher.Mono<org.springframework.http.ResponseEntity<?>> |
get(RequestProcessor.FunctionWrapper wrapper) |
reactor.core.publisher.Mono<org.springframework.http.ResponseEntity<?>> |
post(RequestProcessor.FunctionWrapper wrapper,
org.springframework.web.server.ServerWebExchange exchange) |
reactor.core.publisher.Mono<org.springframework.http.ResponseEntity<?>> |
post(RequestProcessor.FunctionWrapper wrapper,
String body,
boolean stream) |
reactor.core.publisher.Mono<org.springframework.http.ResponseEntity<?>> |
stream(RequestProcessor.FunctionWrapper request) |
static RequestProcessor.FunctionWrapper |
wrapper(Function<? extends org.reactivestreams.Publisher<?>,? extends org.reactivestreams.Publisher<?>> function) |
static RequestProcessor.FunctionWrapper |
wrapper(Function<? extends org.reactivestreams.Publisher<?>,? extends org.reactivestreams.Publisher<?>> function,
Consumer<? extends org.reactivestreams.Publisher<?>> consumer,
Supplier<? extends org.reactivestreams.Publisher<?>> supplier) |
public RequestProcessor(FunctionInspector inspector, FunctionCatalog functionCatalog, org.springframework.beans.factory.ObjectProvider<JsonMapper> mapper, StringConverter converter, org.springframework.beans.factory.ObjectProvider<org.springframework.http.codec.ServerCodecConfigurer> codecs)
public static RequestProcessor.FunctionWrapper wrapper(Function<? extends org.reactivestreams.Publisher<?>,? extends org.reactivestreams.Publisher<?>> function, Consumer<? extends org.reactivestreams.Publisher<?>> consumer, Supplier<? extends org.reactivestreams.Publisher<?>> supplier)
public static RequestProcessor.FunctionWrapper wrapper(Function<? extends org.reactivestreams.Publisher<?>,? extends org.reactivestreams.Publisher<?>> function)
public reactor.core.publisher.Mono<org.springframework.http.ResponseEntity<?>> get(RequestProcessor.FunctionWrapper wrapper)
public reactor.core.publisher.Mono<org.springframework.http.ResponseEntity<?>> post(RequestProcessor.FunctionWrapper wrapper, org.springframework.web.server.ServerWebExchange exchange)
public reactor.core.publisher.Mono<org.springframework.http.ResponseEntity<?>> post(RequestProcessor.FunctionWrapper wrapper, String body, boolean stream)
public reactor.core.publisher.Mono<org.springframework.http.ResponseEntity<?>> stream(RequestProcessor.FunctionWrapper request)
Copyright © 2019 Pivotal Software, Inc.. All rights reserved.