Class HttpSenderOverHTTP.HeadersCallback

java.lang.Object

org.eclipse.jetty.util.IteratingCallback

org.eclipse.jetty.client.http.HttpSenderOverHTTP.HeadersCallback

All Implemented Interfaces:

Callback, Invocable

Enclosing class:

HttpSenderOverHTTP

private class HttpSenderOverHTTP.HeadersCallback
extends IteratingCallback

Nested Class Summary

Nested classes/interfaces inherited from class IteratingCallback

IteratingCallback.Action

Nested classes/interfaces inherited from interface Callback

Callback.Completable, Callback.Completing, Callback.Nested

Nested classes/interfaces inherited from interface Invocable

Invocable.InvocationType

Field Summary

Fields

Modifier and Type	Field	Description
private final Callback	callback
private ByteBuffer	chunkBuffer
private ByteBuffer	contentBuffer
private final HttpExchange	exchange
private boolean	generated
private ByteBuffer	headerBuffer
private boolean	lastContent
private final MetaData.Request	metaData

Fields inherited from interface Callback

NOOP

Fields inherited from interface Invocable

__nonBlocking

Constructor Summary

Constructors

Constructor	Description
HeadersCallback(HttpExchange exchange, HttpContent content, Callback callback)

Method Summary

Modifier and Type	Method	Description
void	failed(Throwable x)	Method to invoke when the asynchronous sub-task fails, or to fail the overall asynchronous task and therefore terminate the iteration.
protected void	onCompleteFailure(Throwable cause)	Invoked when the overall task has completed with a failure.
protected void	onCompleteSuccess()	Invoked when the overall task has completed successfully.
protected IteratingCallback.Action	process()	Method called by IteratingCallback.iterate() to process the asynchronous sub-task.
private void	release()
void	succeeded()	Method to invoke when the asynchronous sub-task succeeds.

Methods inherited from class IteratingCallback

close, isClosed, isFailed, isSucceeded, iterate, reset, toString

Methods inherited from class Object

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

Methods inherited from interface Invocable

getInvocationType

Field Details

exchange

private final HttpExchange exchange

callback

private final Callback callback

metaData

private final MetaData.Request metaData

headerBuffer

private ByteBuffer headerBuffer

chunkBuffer

private ByteBuffer chunkBuffer

contentBuffer

private ByteBuffer contentBuffer

lastContent

private boolean lastContent

generated

private boolean generated

Constructor Details

HeadersCallback

public HeadersCallback(HttpExchange exchange,
 HttpContent content,
 Callback callback)

Method Details

process

protected IteratingCallback.Action process()
                                    throws Exception

Description copied from class: IteratingCallback

Method called by IteratingCallback.iterate() to process the asynchronous sub-task.

Implementations must initiate the asynchronous execution of the sub-task (if any) and return an appropriate action:

• IteratingCallback.Action.IDLE when no sub tasks are available for execution but the overall job is not completed yet
• IteratingCallback.Action.SCHEDULED when the sub task asynchronous execution has been started
• IteratingCallback.Action.SUCCEEDED when the overall job is completed

Specified by:

process in class IteratingCallback

Returns:

the appropriate Action

Throws:

Exception

succeeded

public void succeeded()

Description copied from class: IteratingCallback

Method to invoke when the asynchronous sub-task succeeds.

Subclasses that override this method must always remember to call super.succeeded().

Specified by:

succeeded in interface Callback

Overrides:

succeeded in class IteratingCallback

See Also:

• Callback.failed(Throwable)

failed

public void failed(Throwable x)

Description copied from class: IteratingCallback

Method to invoke when the asynchronous sub-task fails, or to fail the overall asynchronous task and therefore terminate the iteration.

Subclasses that override this method must always remember to call super.failed(Throwable).

Eventually, IteratingCallback.onCompleteFailure(Throwable) is called, either by the caller thread or by the processing thread.

Specified by:

failed in interface Callback

Overrides:

failed in class IteratingCallback

Parameters:

x - the reason for the operation failure

See Also:

• IteratingCallback.isFailed()

onCompleteSuccess

protected void onCompleteSuccess()

Description copied from class: IteratingCallback

Invoked when the overall task has completed successfully.

Overrides:

onCompleteSuccess in class IteratingCallback

See Also:

• IteratingCallback.onCompleteFailure(Throwable)

onCompleteFailure

protected void onCompleteFailure(Throwable cause)

Description copied from class: IteratingCallback

Invoked when the overall task has completed with a failure.

Overrides:

onCompleteFailure in class IteratingCallback

Parameters:

cause - the throwable to indicate cause of failure

See Also:

• IteratingCallback.onCompleteSuccess()

release

private void release()