public class RequestCollapser<BatchReturnType,ResponseType,RequestArgumentType> extends Object
Instances of this are retrieved from the RequestCollapserFactory. Must be thread-safe since it exists within a RequestVariable which is request-scoped and can be accessed from multiple threads.
Modifier and Type | Method and Description |
---|---|
void |
shutdown()
Called from RequestVariable.shutdown() to unschedule the task.
|
rx.Observable<ResponseType> |
submitRequest(RequestArgumentType arg)
Submit a request to a batch.
|
public rx.Observable<ResponseType> submitRequest(RequestArgumentType arg)
arg
- argument to a RequestCollapser
IllegalStateException
- if submitting after shutdownpublic void shutdown()
Copyright © 2020. All Rights Reserved.