org.apache.flink.statefun.flink.core.reqreply

Interface RequestReplyClient

All Known Implementing Classes:

ClassLoaderSafeRequestReplyClient

@PublicEvolving
public interface RequestReplyClient

Method Summary

Modifier and Type	Method and Description
java.util.concurrent.CompletableFuture<FromFunction>	call(ToFunctionRequestSummary requestSummary, RemoteInvocationMetrics metrics, ToFunction toFunction)

Method Detail

call

java.util.concurrent.CompletableFuture<FromFunction> call(ToFunctionRequestSummary requestSummary,
                                                          RemoteInvocationMetrics metrics,
                                                          ToFunction toFunction)