org.springframework.cloud.function.rsocket

Class RSocketListenerFunction

java.lang.Object

org.springframework.cloud.function.rsocket.RSocketListenerFunction

All Implemented Interfaces:

Function<org.springframework.messaging.Message<byte[]>,org.reactivestreams.Publisher<org.springframework.messaging.Message<byte[]>>>

public class RSocketListenerFunction
extends Object
implements Function<org.springframework.messaging.Message<byte[]>,org.reactivestreams.Publisher<org.springframework.messaging.Message<byte[]>>>

Wrapper over an instance of target Function (represented by SimpleFunctionRegistry.FunctionInvocationWrapper) which will use the result of the invocation of such function as an input to another RSocket effectively composing two functions over RSocket.

Since:

3.1

Author:

Oleg Zhurakousky

Method Summary

Modifier and Type	Method and Description
org.reactivestreams.Publisher<org.springframework.messaging.Message<byte[]>>	apply(org.springframework.messaging.Message<byte[]> 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, identity

Method Detail

apply

public org.reactivestreams.Publisher<org.springframework.messaging.Message<byte[]>> apply(org.springframework.messaging.Message<byte[]> input)

Specified by:

apply in interface Function<org.springframework.messaging.Message<byte[]>,org.reactivestreams.Publisher<org.springframework.messaging.Message<byte[]>>>