Package org.apache.hc.core5.reactor

Class IOSessionRequest

java.lang.Object

org.apache.hc.core5.reactor.IOSessionRequest

All Implemented Interfaces:

Future<IOSession>

final class IOSessionRequest
extends Object
implements Future<IOSession>

Field Summary

Fields

Modifier and Type	Field	Description
(package private) final Object	attachment
private final AtomicReference<ModalCloseable>	closeableRef
(package private) final BasicFuture<IOSession>	future
(package private) final SocketAddress	localAddress
(package private) final SocketAddress	remoteAddress
(package private) final NamedEndpoint	remoteEndpoint
(package private) final Timeout	timeout

Constructor Summary

Constructors

Constructor	Description
IOSessionRequest(NamedEndpoint remoteEndpoint, SocketAddress remoteAddress, SocketAddress localAddress, Timeout timeout, Object attachment, FutureCallback<IOSession> callback)

Method Summary

Modifier and Type	Method	Description
void	assign(ModalCloseable closeable)
boolean	cancel()
boolean	cancel(boolean mayInterruptIfRunning)
void	completed(ProtocolIOSession ioSession)
void	failed(Exception cause)
IOSession	get()
IOSession	get(long timeout, TimeUnit unit)
boolean	isCancelled()
boolean	isDone()
String	toString()

Methods inherited from class java.lang.Object

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

Field Details

remoteEndpoint

final NamedEndpoint remoteEndpoint

remoteAddress

final SocketAddress remoteAddress

localAddress

final SocketAddress localAddress

timeout

final Timeout timeout

attachment

final Object attachment

future

final BasicFuture<IOSession> future

closeableRef

private final AtomicReference<ModalCloseable> closeableRef

Constructor Details

IOSessionRequest

public IOSessionRequest(NamedEndpoint remoteEndpoint,
 SocketAddress remoteAddress,
 SocketAddress localAddress,
 Timeout timeout,
 Object attachment,
 FutureCallback<IOSession> callback)

Method Details

completed

public void completed(ProtocolIOSession ioSession)

failed

public void failed(Exception cause)

cancel

public boolean cancel()

cancel

public boolean cancel(boolean mayInterruptIfRunning)

Specified by:

cancel in interface Future<IOSession>

isCancelled

public boolean isCancelled()

Specified by:

isCancelled in interface Future<IOSession>

assign

public void assign(ModalCloseable closeable)

isDone

public boolean isDone()

Specified by:

isDone in interface Future<IOSession>

get

public IOSession get()
              throws InterruptedException,
ExecutionException

Specified by:

get in interface Future<IOSession>

Throws:

InterruptedException

ExecutionException

get

public IOSession get(long timeout,
 TimeUnit unit)
              throws InterruptedException,
ExecutionException,
TimeoutException

Specified by:

get in interface Future<IOSession>

Throws:

InterruptedException

ExecutionException

TimeoutException

toString

public String toString()

Overrides:

toString in class Object