public class PendingRequest extends Object implements Future<Response>
Future
for parameteric T
type Response
used for processing of pipelined responses from the server.
Note that this implementation does NOT support canceling of Request
s.
Constructor and Description |
---|
PendingRequest(Command cmd) |
PendingRequest(Command cmd,
byte[]... args) |
Modifier and Type | Method and Description |
---|---|
boolean |
cancel(boolean mayInterruptIfRunning)
Pipeline does not support canceling of requests -- will always return false.
|
Response |
get() |
Response |
get(long timeout,
TimeUnit unit) |
boolean |
isCancelled()
Pipeline does not support canceling of requests -- will always return false.
|
boolean |
isDone() |
public PendingRequest(Command cmd)
public PendingRequest(Command cmd, byte[]... args)
public Response get() throws InterruptedException, ExecutionException
get
in interface Future<Response>
InterruptedException
ExecutionException
public Response get(long timeout, TimeUnit unit) throws InterruptedException, ExecutionException, TimeoutException
get
in interface Future<Response>
InterruptedException
ExecutionException
TimeoutException
public boolean cancel(boolean mayInterruptIfRunning)
cancel
in interface Future<Response>
Future.cancel(boolean)
public boolean isCancelled()
isCancelled
in interface Future<Response>
cancel(boolean)
,
Future.isCancelled()
Copyright © 2009–2019. All rights reserved.