static final class ChunkedPipelineConnection.PendingCPRequest extends PendingRequest
PendingRequest. This class
maintains a reference to the pipeline to allow for transparent
invokation of .| Modifier and Type | Field and Description |
|---|---|
private ChunkedPipelineConnection |
pipeline |
args, cmd, completion, response| Constructor and Description |
|---|
PendingCPRequest(ChunkedPipelineConnection pipeline,
Command cmd) |
| Modifier and Type | Method and Description |
|---|---|
Response |
get() |
Response |
get(long timeout,
java.util.concurrent.TimeUnit unit) |
private void |
requestFlush() |
cancel, getCommand, isCancelled, isDone, setCRE, setResponseprivate final ChunkedPipelineConnection pipeline
PendingCPRequest(ChunkedPipelineConnection pipeline, Command cmd)
public final Response get() throws java.lang.InterruptedException, java.util.concurrent.ExecutionException
get in interface java.util.concurrent.Future<Response>get in class PendingRequestjava.lang.InterruptedExceptionjava.util.concurrent.ExecutionExceptionpublic final Response get(long timeout, java.util.concurrent.TimeUnit unit) throws java.lang.InterruptedException, java.util.concurrent.ExecutionException, java.util.concurrent.TimeoutException
get in interface java.util.concurrent.Future<Response>get in class PendingRequestjava.lang.InterruptedExceptionjava.util.concurrent.ExecutionExceptionjava.util.concurrent.TimeoutExceptionprivate final void requestFlush()