public class FetchWaiter extends java.lang.Object implements ClientGetCallback
| Constructor and Description |
|---|
FetchWaiter(RequestClient client) |
| Modifier and Type | Method and Description |
|---|---|
RequestClient |
getRequestClient()
Get the RequestClient context object used to indicate which requests are related to each
other for scheduling purposes.
|
void |
onFailure(FetchException e,
ClientGetter state)
Called on failed/canceled fetch.
|
void |
onResume(ClientContext context)
Called for a persistent request when the node is restarted.
|
void |
onSuccess(FetchResult result,
ClientGetter state)
Called on successful fetch.
|
FetchResult |
waitForCompletion()
Wait for the request to complete, return the results, throw if it failed.
|
public FetchWaiter(RequestClient client)
public void onSuccess(FetchResult result, ClientGetter state)
ClientGetCallbackonSuccess in interface ClientGetCallbackpublic void onFailure(FetchException e, ClientGetter state)
ClientGetCallbackonFailure in interface ClientGetCallbackpublic FetchResult waitForCompletion() throws FetchException
FetchExceptionpublic void onResume(ClientContext context)
ClientBaseCallbackonResume in interface ClientBaseCallbackpublic RequestClient getRequestClient()
ClientBaseCallbackgetRequestClient in interface ClientBaseCallback