Package org.springframework.cloud.function.context.catalog

Class MessageFunction

java.lang.Object

org.springframework.cloud.function.context.catalog.MessageFunction

All Implemented Interfaces:

Function<org.reactivestreams.Publisher<?>,org.reactivestreams.Publisher<org.springframework.messaging.Message<?>>>

public class MessageFunction
extends Object
implements Function<org.reactivestreams.Publisher<?>,org.reactivestreams.Publisher<org.springframework.messaging.Message<?>>>

Since:

2.1

Author:

Dave Syer

Constructor Summary

Constructors

Constructor	Description
MessageFunction(Function<?,?> delegate)

Method Summary

Modifier and Type	Method	Description
org.reactivestreams.Publisher<org.springframework.messaging.Message<?>>	apply(org.reactivestreams.Publisher<?> input)

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.util.function.Function

andThen, compose

Constructor Details

MessageFunction

public MessageFunction(Function<?,?> delegate)

Method Details

apply

public org.reactivestreams.Publisher<org.springframework.messaging.Message<?>> apply(org.reactivestreams.Publisher<?> input)

Specified by:

apply in interface Function<org.reactivestreams.Publisher<?>,org.reactivestreams.Publisher<org.springframework.messaging.Message<?>>>