Class SimpleFunctionRegistry.FunctionInvocationWrapper

java.lang.Object
org.springframework.cloud.function.context.catalog.SimpleFunctionRegistry.FunctionInvocationWrapper
All Implemented Interfaces:
Runnable, Consumer<Object>, Function<Object,Object>, Supplier<Object>
Enclosing class:
SimpleFunctionRegistry
public class SimpleFunctionRegistry.FunctionInvocationWrapper extends Object implements Function<Object,Object>, Consumer<Object>, Supplier<Object>, Runnable
Author:
Oleg Zhurakousky, Roman Samarev, Soby Chacko, Chris Bono

  • Field Details

    • wrapped

      protected boolean wrapped

  • Method Details

    • postProcess

      public void postProcess()

    • isWrappedBiConsumer

      public boolean isWrappedBiConsumer()

    • setWrappedBiConsumer

      public void setWrappedBiConsumer(boolean wrappedBiConsumer)

    • setPojoFunction

      public void setPojoFunction(boolean isPojoFunction)

    • isPojoFunction

      public boolean isPojoFunction()

    • isSkipOutputConversion

      public boolean isSkipOutputConversion()

    • isSkipInputConversion

      public boolean isSkipInputConversion()

    • isPrototype

      public boolean isPrototype()

    • setSkipInputConversion

      public void setSkipInputConversion(boolean skipInputConversion)

    • setSkipOutputConversion

      public void setSkipOutputConversion(boolean skipOutputConversion)

    • getEnhancer

      public Function<Object,Object> getEnhancer()
      !!! INTERNAL USE ONLY !!! This is primarily to support s-c-Stream's ability to access un-converted payload (e.g., to evaluate expression on some attribute of a payload) It is not intended to remain here and will be removed as soon as particular elements of stream will be refactored to address this.

    • getOutputType

      public Type getOutputType()

    • setEnhancer

      public void setEnhancer(Function<Object,Object> enhancer)
      !!! INTERNAL USE ONLY !!! This is primarily to support s-c-Stream's ability to access un-converted payload (e.g., to evaluate expression on some attribute of a payload) It is not intended to remain here and will be removed as soon as particular elements of stream will be refactored to address this.

    • getTarget

      public Object getTarget()

    • getInputType

      public Type getInputType()

    • getItemType

      public Type getItemType(Type type)
      Return the actual Type of the item of the provided type. This method is context specific and is not a general purpose utility method. The context is that the provided Type may represent the input/output of a function where such type could be wrapped in Message, Flux or Mono, so this method returns generic value of such type or itself if not wrapped.
      Parameters:
      type - typically input or output Type of the function (see getInputType() or getOutputType().
      Returns:
      the type of the item if wrapped otherwise the provided type.

    • getRawOutputType

      public Class<?> getRawOutputType()

    • getRawInputType

      public Class<?> getRawInputType()

    • apply

      public Object apply(Object input)
      Specified by:
      apply in interface Function<Object,Object>

    • get

      public Object get()
      Specified by:
      get in interface Supplier<Object>

    • accept

      public void accept(Object input)
      Specified by:
      accept in interface Consumer<Object>

    • run

      public void run()
      Specified by:
      run in interface Runnable

    • isConsumer

      public boolean isConsumer()

    • isSupplier

      public boolean isSupplier()

    • isFunction

      public boolean isFunction()

    • isInputTypePublisher

      public boolean isInputTypePublisher()

    • isOutputTypePublisher

      public boolean isOutputTypePublisher()

    • isInputTypeMessage

      public boolean isInputTypeMessage()

    • isOutputTypeMessage

      public boolean isOutputTypeMessage()

    • isRoutingFunction

      public boolean isRoutingFunction()

    • andThen

      public <V> Function<Object,V> andThen(Function<? super Object, ? extends V> after)
      Specified by:
      andThen in interface Function<Object,Object>

    • getFunctionDefinition

      public String getFunctionDefinition()
      Returns the definition of this function.
      Returns:
      function definition

    • toString

      public String toString()
      Overrides:
      toString in class Object

    • isComposed

      public boolean isComposed()
      Returns true if this function wrapper represents a composed function.
      Returns:
      true if this function wrapper represents a composed function otherwise false