Class TimeoutCompleteListener

java.lang.Object

org.eclipse.jetty.io.CyclicTimeout

org.eclipse.jetty.client.TimeoutCompleteListener

All Implemented Interfaces:

EventListener, Response.CompleteListener, Response.ResponseListener, Destroyable

public class TimeoutCompleteListener
extends CyclicTimeout
implements Response.CompleteListener

Field Summary

Fields

Modifier and Type	Field	Description
private static final Logger	LOG
private final AtomicReference<Request>	request

Constructor Summary

Constructors

Constructor	Description
TimeoutCompleteListener(Scheduler scheduler)

Method Summary

Modifier and Type	Method	Description
void	onComplete(Result result)	Callback method invoked when the request and the response have been processed, either successfully or not.
void	onTimeoutExpired()	Invoked when the timeout expires.
(package private) void	schedule(HttpRequest request, long timeoutAt)

Methods inherited from class CyclicTimeout

cancel, destroy, getScheduler, schedule

Methods inherited from class Object

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

Field Details

LOG

private static final Logger LOG

request

private final AtomicReference<Request> request

Constructor Details

TimeoutCompleteListener

public TimeoutCompleteListener(Scheduler scheduler)

Method Details

onTimeoutExpired

public void onTimeoutExpired()

Description copied from class: CyclicTimeout

Invoked when the timeout expires.

Specified by:

onTimeoutExpired in class CyclicTimeout

onComplete

public void onComplete(Result result)

Description copied from interface: Response.CompleteListener

Callback method invoked when the request and the response have been processed, either successfully or not.

The result parameter contains the request, the response, and eventual failures.

Requests may complete after response, for example in case of big uploads that are discarded or read asynchronously by the server. This method is always invoked after Response.SuccessListener.onSuccess(Response) or Response.FailureListener.onFailure(Response, Throwable), and only when request indicates that it is completed.

Specified by:

onComplete in interface Response.CompleteListener

Parameters:

result - the result of the request / response exchange

schedule

void schedule(HttpRequest request,
 long timeoutAt)