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 and Description
static class	RequestProcessor.FunctionWrapper

Constructor Summary

Constructors

Constructor and Description
RequestProcessor(JsonMapper mapper, FunctionInspector inspector, StringConverter converter)

Method Summary

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, String body, boolean stream)
reactor.core.publisher.Mono<org.springframework.http.ResponseEntity<?>>	stream(RequestProcessor.FunctionWrapper request)
static RequestProcessor.FunctionWrapper	wrapper(Function<org.reactivestreams.Publisher<?>,org.reactivestreams.Publisher<?>> function, Consumer<org.reactivestreams.Publisher<?>> consumer, Supplier<org.reactivestreams.Publisher<?>> supplier)

Methods inherited from class java.lang.Object

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

Constructor Detail

RequestProcessor

public RequestProcessor(JsonMapper mapper,
                        FunctionInspector inspector,
                        StringConverter converter)

Method Detail

wrapper

public static RequestProcessor.FunctionWrapper wrapper(Function<org.reactivestreams.Publisher<?>,org.reactivestreams.Publisher<?>> function,
                                                       Consumer<org.reactivestreams.Publisher<?>> consumer,
                                                       Supplier<org.reactivestreams.Publisher<?>> supplier)

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 request)