Class IOSessionRequest

java.lang.Object

org.apache.hc.core5.reactor.IOSessionRequest

All Implemented Interfaces:

Future<IOSession>

final class IOSessionRequest
extends Object
implements Future<IOSession>

Nested Class Summary

Nested classes/interfaces inherited from interface Future

Future.State

Field Summary

Fields

Modifier and Type	Field	Description
(package private) final Object	attachment
private final AtomicReference<ModalCloseable>	closeableRef
private final long	enqueueTime
(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)
long	getEnqueueTime()
boolean	isCancelled()
boolean	isDone()
String	toString()

Methods inherited from class Object

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

Methods inherited from interface Future

exceptionNow, resultNow, state

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

enqueueTime

private final long enqueueTime

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

getEnqueueTime

@Internal
public long getEnqueueTime()