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> |
|