public interface BlockingService
Service
.Modifier and Type | Method and Description |
---|---|
Message |
callBlockingMethod(Descriptors.MethodDescriptor method,
RpcController controller,
Message request)
Equivalent to
Service.callMethod(org.apache.flink.statefun.sdk.shaded.com.google.protobuf.Descriptors.MethodDescriptor, org.apache.flink.statefun.sdk.shaded.com.google.protobuf.RpcController, org.apache.flink.statefun.sdk.shaded.com.google.protobuf.Message, org.apache.flink.statefun.sdk.shaded.com.google.protobuf.RpcCallback<org.apache.flink.statefun.sdk.shaded.com.google.protobuf.Message>) , except that callBlockingMethod() returns the
result of the RPC or throws a ServiceException if there is a failure, rather than
passing the information to a callback. |
Descriptors.ServiceDescriptor |
getDescriptorForType()
Equivalent to
Service.getDescriptorForType() . |
Message |
getRequestPrototype(Descriptors.MethodDescriptor method)
|
Message |
getResponsePrototype(Descriptors.MethodDescriptor method)
|
Descriptors.ServiceDescriptor getDescriptorForType()
Service.getDescriptorForType()
.Message callBlockingMethod(Descriptors.MethodDescriptor method, RpcController controller, Message request) throws ServiceException
Service.callMethod(org.apache.flink.statefun.sdk.shaded.com.google.protobuf.Descriptors.MethodDescriptor, org.apache.flink.statefun.sdk.shaded.com.google.protobuf.RpcController, org.apache.flink.statefun.sdk.shaded.com.google.protobuf.Message, org.apache.flink.statefun.sdk.shaded.com.google.protobuf.RpcCallback<org.apache.flink.statefun.sdk.shaded.com.google.protobuf.Message>)
, except that callBlockingMethod()
returns the
result of the RPC or throws a ServiceException
if there is a failure, rather than
passing the information to a callback.ServiceException
Message getRequestPrototype(Descriptors.MethodDescriptor method)
Message getResponsePrototype(Descriptors.MethodDescriptor method)
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.