Package org.springframework.cloud.function.web

Class RequestProcessor

java.lang.Object

org.springframework.cloud.function.web.RequestProcessor

public class RequestProcessor
extends Object

Author:

Dave Syer, Oleg Zhurakousky

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	RequestProcessor.FunctionWrapper	Wrapper for functions.

Constructor Summary

Constructors

Constructor	Description
RequestProcessor(JsonMapper mapper, org.springframework.beans.factory.ObjectProvider<org.springframework.http.codec.ServerCodecConfigurer> codecs)

Method Summary

Modifier and Type	Method	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, String body, boolean stream)
reactor.core.publisher.Mono<org.springframework.http.ResponseEntity<?>>	response(RequestProcessor.FunctionWrapper wrapper, Object body, boolean stream)
reactor.core.publisher.Mono<org.springframework.http.ResponseEntity<?>>	stream(RequestProcessor.FunctionWrapper functionWrapper)
static RequestProcessor.FunctionWrapper	wrapper(SimpleFunctionRegistry.FunctionInvocationWrapper function)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

RequestProcessor

public RequestProcessor(JsonMapper mapper,
 org.springframework.beans.factory.ObjectProvider<org.springframework.http.codec.ServerCodecConfigurer> codecs)

Method Details

wrapper

public static RequestProcessor.FunctionWrapper wrapper(SimpleFunctionRegistry.FunctionInvocationWrapper function)

get

public reactor.core.publisher.Mono<org.springframework.http.ResponseEntity<?>> get(RequestProcessor.FunctionWrapper wrapper)

post

public reactor.core.publisher.Mono<org.springframework.http.ResponseEntity<?>> post(RequestProcessor.FunctionWrapper wrapper,
 String body,
 boolean stream)

stream

public reactor.core.publisher.Mono<org.springframework.http.ResponseEntity<?>> stream(RequestProcessor.FunctionWrapper functionWrapper)

response

public reactor.core.publisher.Mono<org.springframework.http.ResponseEntity<?>> response(RequestProcessor.FunctionWrapper wrapper,
 Object body,
 boolean stream)