Package org.apache.hc.core5.testing.nio

Class AsyncRequester

java.lang.Object

org.apache.hc.core5.testing.nio.AsyncRequester

All Implemented Interfaces:

AutoCloseable, ConnectionInitiator

Direct Known Subclasses:

HttpTestClient

public class AsyncRequester
extends Object
implements ConnectionInitiator

Constructor Summary

Constructors

Constructor	Description
AsyncRequester(IOReactorConfig ioReactorConfig)

Method Summary

Modifier and Type	Method	Description
void	awaitShutdown(TimeValue waitTime)
void	close()
Future<IOSession>	connect(NamedEndpoint remoteEndpoint, SocketAddress remoteAddress, SocketAddress localAddress, Timeout timeout, Object attachment, FutureCallback<IOSession> callback)
protected void	execute(IOEventHandlerFactory ioEventHandlerFactory)
IOReactorStatus	getStatus()
void	initiateShutdown()
Future<IOSession>	requestSession(HttpHost host, Timeout timeout, FutureCallback<IOSession> callback)
void	shutdown(TimeValue graceTime)

Methods inherited from class java.lang.Object

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

Constructor Details

AsyncRequester

public AsyncRequester(IOReactorConfig ioReactorConfig)

Method Details

requestSession

public Future<IOSession> requestSession(HttpHost host,
 Timeout timeout,
 FutureCallback<IOSession> callback)

connect

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

Specified by:

connect in interface ConnectionInitiator

execute

protected void execute(IOEventHandlerFactory ioEventHandlerFactory)
                throws IOException

Throws:

IOException

getStatus

public IOReactorStatus getStatus()

awaitShutdown

public void awaitShutdown(TimeValue waitTime)
                   throws InterruptedException

Throws:

InterruptedException

initiateShutdown

public void initiateShutdown()

shutdown

public void shutdown(TimeValue graceTime)

close

public void close()
           throws Exception

Specified by:

close in interface AutoCloseable

Throws:

Exception