Package | Description |
---|---|
org.apache.flink.statefun.sdk.shaded.com.google.protobuf |
Modifier and Type | Method and Description |
---|---|
static <Type extends Message> |
RpcUtil.generalizeCallback(RpcCallback<Type> originalCallback,
java.lang.Class<Type> originalClass,
Type defaultInstance)
Take an
RpcCallback accepting a specific message type and convert it to an RpcCallback<Message> . |
static <ParameterType> |
RpcUtil.newOneTimeCallback(RpcCallback<ParameterType> originalCallback)
Creates a callback which can only be called once.
|
static <Type extends Message> |
RpcUtil.specializeCallback(RpcCallback<Message> originalCallback)
Take an
RpcCallback<Message> and convert it to an RpcCallback accepting a
specific message type. |
Modifier and Type | Method and Description |
---|---|
void |
RpcChannel.callMethod(Descriptors.MethodDescriptor method,
RpcController controller,
Message request,
Message responsePrototype,
RpcCallback<Message> done)
Call the given method of the remote service.
|
void |
Service.callMethod(Descriptors.MethodDescriptor method,
RpcController controller,
Message request,
RpcCallback<Message> done)
Call a method of the service specified by MethodDescriptor.
|
static <Type extends Message> |
RpcUtil.generalizeCallback(RpcCallback<Type> originalCallback,
java.lang.Class<Type> originalClass,
Type defaultInstance)
Take an
RpcCallback accepting a specific message type and convert it to an RpcCallback<Message> . |
static <ParameterType> |
RpcUtil.newOneTimeCallback(RpcCallback<ParameterType> originalCallback)
Creates a callback which can only be called once.
|
void |
RpcController.notifyOnCancel(RpcCallback<java.lang.Object> callback)
Asks that the given callback be called when the RPC is canceled.
|
static <Type extends Message> |
RpcUtil.specializeCallback(RpcCallback<Message> originalCallback)
Take an
RpcCallback<Message> and convert it to an RpcCallback accepting a
specific message type. |
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.