org.springframework.cloud.function.web.flux

Class FunctionController

java.lang.Object

org.springframework.cloud.function.web.flux.FunctionController

@Component
public class FunctionController
extends Object

Author:

Dave Syer, Mark Fisher

Constructor Summary

Constructors

Constructor and Description
FunctionController(FunctionInspector inspector)

Method Summary

Modifier and Type	Method and Description
Object	get(Function<reactor.core.publisher.Flux<?>,reactor.core.publisher.Flux<?>> function, Supplier<reactor.core.publisher.Flux<?>> supplier, String argument)
org.springframework.http.ResponseEntity<reactor.core.publisher.Flux<?>>	post(Function<reactor.core.publisher.Flux<?>,reactor.core.publisher.Flux<?>> function, Consumer<reactor.core.publisher.Flux<?>> consumer, Boolean single, FluxRequest<?> body)
void	setDebug(boolean debug)

Methods inherited from class java.lang.Object

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

Constructor Detail

FunctionController

public FunctionController(FunctionInspector inspector)

Method Detail

setDebug

public void setDebug(boolean debug)

post

@PostMapping(path="/**")
 @ResponseBody
public org.springframework.http.ResponseEntity<reactor.core.publisher.Flux<?>> post(@RequestAttribute(required=false,name="org.springframework.cloud.function.web.flux.constants.WebRequestConstants.function")
                                                                                                                            Function<reactor.core.publisher.Flux<?>,reactor.core.publisher.Flux<?>> function,
                                                                                                                            @RequestAttribute(required=false,name="org.springframework.cloud.function.web.flux.constants.WebRequestConstants.consumer")
                                                                                                                            Consumer<reactor.core.publisher.Flux<?>> consumer,
                                                                                                                            @RequestAttribute(required=false,name="org.springframework.cloud.function.web.flux.constants.WebRequestConstants.input_single")
                                                                                                                            Boolean single,
                                                                                                                            @RequestBody
                                                                                                                            FluxRequest<?> body)

get

@GetMapping(path="/**")
 @ResponseBody
public Object get(@RequestAttribute(required=false,name="org.springframework.cloud.function.web.flux.constants.WebRequestConstants.function")
                                                         Function<reactor.core.publisher.Flux<?>,reactor.core.publisher.Flux<?>> function,
                                                         @RequestAttribute(required=false,name="org.springframework.cloud.function.web.flux.constants.WebRequestConstants.supplier")
                                                         Supplier<reactor.core.publisher.Flux<?>> supplier,
                                                         @RequestAttribute(required=false,name="org.springframework.cloud.function.web.flux.constants.WebRequestConstants.argument")
                                                         String argument)