PlainTransportFuture

java.lang.Object
- org.elasticsearch.common.util.concurrent.BaseFuture<V>
- - org.elasticsearch.transport.PlainTransportFuture<V>

All Implemented Interfaces:: Future<V>, TransportFuture<V>, TransportResponseHandler<V>

public class PlainTransportFuture<V extends TransportResponse>
extends BaseFuture<V>
implements TransportFuture<V>, TransportResponseHandler<V>

Constructor Summary

Constructors

Constructor and Description
`PlainTransportFuture(TransportResponseHandler<V> handler)`

Method Summary

All Methods

Instance Methods

Concrete Methods
Modifier and Type	Method and Description
`String`	`executor()`
`void`	`handleException(TransportException exp)`
`void`	`handleResponse(V response)`
`V`	`newInstance()` creates a new instance of the return type from the remote call.
`String`	`toString()`
`V`	`txGet()` Waits if necessary for the computation to complete, and then retrieves its result.
`V`	`txGet(long timeout, TimeUnit 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
cancel, done, get, get, interruptTask, isCancelled, isDone, set, setException

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface java.util.concurrent.Future
cancel, get, get, isCancelled, isDone

- Constructor Detail
  - PlainTransportFuture
```
public PlainTransportFuture(TransportResponseHandler<V> handler)
```
- Method Detail
  - txGet
```
public V txGet()
        throws ElasticsearchException
```
    Description copied from interface: TransportFuture
    
    Waits if necessary for the computation to complete, and then retrieves its result.
    
    Specified by:
    
    txGet in interface TransportFuture<V extends TransportResponse>
    
    Throws:
    
    ElasticsearchException
  - txGet
```
public V txGet(long timeout,
               TimeUnit unit)
        throws ElasticsearchException
```
    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 interface TransportFuture<V extends TransportResponse>
    
    Throws:
    
    ElasticsearchException
  - newInstance
```
public V newInstance()
```
    Description copied from interface: TransportResponseHandler
    
    creates a new instance of the return type from the remote call. called by the infra before de-serializing the response.
    
    Specified by:
    
    newInstance in interface TransportResponseHandler<V extends TransportResponse>
    
    Returns:
    
    a new response copy.
  - executor
```
public String executor()
```
  - handleResponse
```
public void handleResponse(V response)
```
  - handleException
```
public void handleException(TransportException exp)
```
  - toString
```
public String toString()
```

Class PlainTransportFuture<V extends TransportResponse>

Constructor Summary

Constructors

Method Summary

Methods inherited from class org.elasticsearch.common.util.concurrent.BaseFuture

Methods inherited from class java.lang.Object

Methods inherited from interface java.util.concurrent.Future

Constructor Detail

PlainTransportFuture

Method Detail

txGet

txGet

newInstance

executor

handleResponse

handleException

toString