Package org.elasticsearch.transport
Class PlainTransportFuture<V extends TransportResponse>
org.elasticsearch.common.util.concurrent.BaseFuture<V>
org.elasticsearch.transport.PlainTransportFuture<V>
- All Implemented Interfaces:
<V>
,Writeable.Reader<V>
,TransportFuture<V>
,TransportResponseHandler<V>
public class PlainTransportFuture<V extends TransportResponse>
extends BaseFuture<V>
implements TransportFuture<V>, TransportResponseHandler<V>
-
Nested Class Summary
Nested classes/interfaces inherited from interface org.elasticsearch.transport.TransportResponseHandler
TransportResponseHandler.Empty
-
Constructor Summary
-
Method Summary
Modifier and TypeMethodDescriptionexecutor()
void
void
handleResponse(V response)
read(StreamInput in)
ReadV
-type value from a stream.toString()
txGet()
Waits if necessary for the computation to complete, and then retrieves its result.txGet(long timeout, unit)
Waits if necessary for at most the given time for the computation to complete, and then retrieves its result, if available.Methods inherited from class org.elasticsearch.common.util.concurrent.BaseFuture
blockingAllowed, cancel, done, get, get, interruptTask, isCancelled, isDone, set, setException
Methods inherited from class java.lang.
, , , , , , , , ,
Methods inherited from interface java.util.concurrent.
, , , ,
Methods inherited from interface org.elasticsearch.transport.TransportResponseHandler
wrap
-
Constructor Details
-
PlainTransportFuture
-
-
Method Details
-
txGet
Description copied from interface:TransportFuture
Waits if necessary for the computation to complete, and then retrieves its result.- Specified by:
txGet
in interfaceTransportFuture<V extends TransportResponse>
-
txGet
Description copied from interface:TransportFuture
Waits if necessary for at most the given time for the computation to complete, and then retrieves its result, if available.- Specified by:
txGet
in interfaceTransportFuture<V extends TransportResponse>
-
read
Description copied from interface:Writeable.Reader
ReadV
-type value from a stream.- Specified by:
read
in interfaceWriteable.Reader<V extends TransportResponse>
- Parameters:
in
- Input to read the value from- Throws:
-
executor
public executor()- Specified by:
executor
in interfaceTransportResponseHandler<V extends TransportResponse>
-
handleResponse
- Specified by:
handleResponse
in interfaceTransportResponseHandler<V extends TransportResponse>
-
handleException
- Specified by:
handleException
in interfaceTransportResponseHandler<V extends TransportResponse>
-
toString
public toString()- Overrides:
in class
-