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)
ClientGetCallback
onSuccess
in interface ClientGetCallback
public void onFailure(FetchException e, ClientGetter state)
ClientGetCallback
onFailure
in interface ClientGetCallback
public FetchResult waitForCompletion() throws FetchException
FetchException
public void onResume(ClientContext context)
ClientBaseCallback
onResume
in interface ClientBaseCallback
public RequestClient getRequestClient()
ClientBaseCallback
getRequestClient
in interface ClientBaseCallback