public class BatchingCallable<RequestT,ResponseT> extends UnaryCallable<RequestT,ResponseT>
A UnaryCallable which will batch requests based on the given BatchingDescriptor and BatcherFactory. The BatcherFactory provides a distinct Batcher for each partition as specified by the BatchingDescriptor. An example of a batching partition would be a pubsub topic.
This is public only for technical reasons, for advanced usage.
Type Parameters |
|
---|---|
Name | Description |
RequestT |
|
ResponseT |
Constructors
BatchingCallable(UnaryCallable<RequestT,ResponseT> callable, BatchingDescriptor<RequestT,ResponseT> batchingDescriptor, BatcherFactory<RequestT,ResponseT> batcherFactory)
public BatchingCallable(UnaryCallable<RequestT,ResponseT> callable, BatchingDescriptor<RequestT,ResponseT> batchingDescriptor, BatcherFactory<RequestT,ResponseT> batcherFactory)
Parameters | |
---|---|
Name | Description |
callable |
UnaryCallable<RequestT,ResponseT> |
batchingDescriptor |
BatchingDescriptor<RequestT,ResponseT> |
batcherFactory |
BatcherFactory<RequestT,ResponseT> |
Methods
futureCall(RequestT request, ApiCallContext context)
public ApiFuture<ResponseT> futureCall(RequestT request, ApiCallContext context)
Perform a call asynchronously.
Parameters | |
---|---|
Name | Description |
request |
RequestT |
context |
ApiCallContext |
Returns | |
---|---|
Type | Description |
ApiFuture<ResponseT> |