org.jredis.ri.alphazero.connection

Class ChunkedPipelineConnection.PendingCPRequest

java.lang.Object

org.jredis.ri.alphazero.connection.PendingRequest

org.jredis.ri.alphazero.connection.ChunkedPipelineConnection.PendingCPRequest

All Implemented Interfaces:

java.util.concurrent.Future<Response>

Enclosing class:

ChunkedPipelineConnection

static final class ChunkedPipelineConnection.PendingCPRequest
extends PendingRequest

ChunkedPipeline specific of PendingRequest. This class maintains a reference to the pipeline to allow for transparent invokation of .

Field Summary

Fields

Modifier and Type	Field and Description
private ChunkedPipelineConnection	pipeline

Fields inherited from class org.jredis.ri.alphazero.connection.PendingRequest

args, cmd, completion, response

Constructor Summary

Constructors

Constructor and Description
PendingCPRequest(ChunkedPipelineConnection pipeline, Command cmd)

Method Summary

Modifier and Type	Method and Description
Response	get()
Response	get(long timeout, java.util.concurrent.TimeUnit unit)
private void	requestFlush()

Methods inherited from class org.jredis.ri.alphazero.connection.PendingRequest

cancel, getCommand, isCancelled, isDone, setCRE, setResponse

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

pipeline

private final ChunkedPipelineConnection pipeline

Constructor Detail

PendingCPRequest

PendingCPRequest(ChunkedPipelineConnection pipeline,
                 Command cmd)

Method Detail

get

public final Response get()
                   throws java.lang.InterruptedException,
                          java.util.concurrent.ExecutionException

Specified by:

get in interface java.util.concurrent.Future<Response>

Overrides:

get in class PendingRequest

Throws:

java.lang.InterruptedException

java.util.concurrent.ExecutionException

get

public final Response get(long timeout,
                          java.util.concurrent.TimeUnit unit)
                   throws java.lang.InterruptedException,
                          java.util.concurrent.ExecutionException,
                          java.util.concurrent.TimeoutException

Specified by:

get in interface java.util.concurrent.Future<Response>

Overrides:

get in class PendingRequest

Throws:

java.lang.InterruptedException

java.util.concurrent.ExecutionException

java.util.concurrent.TimeoutException

requestFlush

private final void requestFlush()