BatchReturnType
- ResponseType
- RequestArgumentType
- public class RequestBatch<BatchReturnType,ResponseType,RequestArgumentType> extends Object
Constructor and Description |
---|
RequestBatch(HystrixCollapserProperties properties,
HystrixCollapserBridge<BatchReturnType,ResponseType,RequestArgumentType> commandCollapser,
int maxBatchSize) |
Modifier and Type | Method and Description |
---|---|
void |
executeBatchIfNotAlreadyStarted()
Collapsed requests are triggered for batch execution and the array of arguments is passed in.
|
rx.Observable<ResponseType> |
offer(RequestArgumentType arg) |
void |
shutdown() |
public RequestBatch(HystrixCollapserProperties properties, HystrixCollapserBridge<BatchReturnType,ResponseType,RequestArgumentType> commandCollapser, int maxBatchSize)
public rx.Observable<ResponseType> offer(RequestArgumentType arg)
public void executeBatchIfNotAlreadyStarted()
IMPORTANT IMPLEMENTATION DETAILS => The expected contract (responsibilities) of this method implementation is:
public void shutdown()
Copyright © 2020. All Rights Reserved.