Package org.eclipse.jetty.fcgi.client.transport.internal

Class HttpReceiverOverFCGI

java.lang.Object

org.eclipse.jetty.client.transport.HttpReceiver

org.eclipse.jetty.fcgi.client.transport.internal.HttpReceiverOverFCGI

public class HttpReceiverOverFCGI
extends HttpReceiver

Constructor Summary

Constructors

Constructor	Description
HttpReceiverOverFCGI(HttpChannel channel)

Method Summary

Modifier and Type	Method	Description
protected void	dispose()	Disposes the state of this HttpReceiver.
void	failAndClose(Throwable failure)	Fails the receiver and closes the underlying stream.
protected HttpChannelOverFCGI	getHttpChannel()
void	onInterim()	Prepare for the next step after an interim response was read.
Content.Chunk	read(boolean fillInterestIfNeeded)	Reads a chunk of data.
protected void	reset()	Resets the state of this HttpReceiver.
protected void	responseBegin(HttpExchange exchange)	Method to be invoked when the response status code is available.
protected void	responseContentAvailable(HttpExchange exchange)	Method to be invoked when response content is available to be read.
protected void	responseFailure(Throwable failure, Promise<Boolean> promise)	Method to be invoked when the response is failed.
protected void	responseHeader(HttpExchange exchange, HttpField field)	Method to be invoked when a response HTTP header is available.
protected void	responseHeaders(HttpExchange exchange)	Method to be invoked after all response HTTP headers are available.

Methods inherited from class org.eclipse.jetty.client.transport.HttpReceiver

abort, getHttpDestination, getHttpExchange, hasContent, isFailed, responseSuccess, storeCookie, toString

Methods inherited from class java.lang.Object

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

Constructor Details

HttpReceiverOverFCGI

public HttpReceiverOverFCGI(HttpChannel channel)

Method Details

onInterim

public void onInterim()

Description copied from class: HttpReceiver

Prepare for the next step after an interim response was read.

Specified by:

onInterim in class HttpReceiver

reset

protected void reset()

Description copied from class: HttpReceiver

Resets the state of this HttpReceiver.

Subclasses should override (but remember to call super) to reset their own state.

Either this method or HttpReceiver.dispose() is called.

Overrides:

reset in class HttpReceiver

dispose

protected void dispose()

Description copied from class: HttpReceiver

Disposes the state of this HttpReceiver.

Subclasses should override (but remember to call super) to dispose their own state.

Either this method or HttpReceiver.reset() is called.

Overrides:

dispose in class HttpReceiver

read

public Content.Chunk read(boolean fillInterestIfNeeded)

Description copied from class: HttpReceiver

Reads a chunk of data.

If no data was read, null is returned and if fillInterestIfNeeded is true then fill interest is registered.

The returned chunk of data may be the last one or an error exactly like Content.Source.read() specifies.

Specified by:

read in class HttpReceiver

Parameters:

fillInterestIfNeeded - true to register for fill interest when no data was read.

Returns:

the chunk of data that was read, or null if nothing was read.

failAndClose

public void failAndClose(Throwable failure)

Description copied from class: HttpReceiver

Fails the receiver and closes the underlying stream.

Specified by:

failAndClose in class HttpReceiver

Parameters:

failure - the failure.

getHttpChannel

protected HttpChannelOverFCGI getHttpChannel()

Overrides:

getHttpChannel in class HttpReceiver

responseBegin

protected void responseBegin(HttpExchange exchange)

Description copied from class: HttpReceiver

Method to be invoked when the response status code is available.

Subclasses must have set the response status code on the Response object of the HttpExchange prior invoking this method.

This method takes case of notifying Response.BeginListeners.

Overrides:

responseBegin in class HttpReceiver

Parameters:

exchange - the HTTP exchange

responseHeader

protected void responseHeader(HttpExchange exchange,
 HttpField field)

Description copied from class: HttpReceiver

Method to be invoked when a response HTTP header is available.

Subclasses must not have added the header to the Response object of the HttpExchange prior invoking this method.

This method takes case of notifying Response.HeaderListeners and storing cookies.

Overrides:

responseHeader in class HttpReceiver

Parameters:

exchange - the HTTP exchange

field - the response HTTP field

responseHeaders

protected void responseHeaders(HttpExchange exchange)

Description copied from class: HttpReceiver

Method to be invoked after all response HTTP headers are available.

This method takes care of notifying Response.HeadersListeners.

Overrides:

responseHeaders in class HttpReceiver

Parameters:

exchange - the HTTP exchange

responseContentAvailable

protected void responseContentAvailable(HttpExchange exchange)

Description copied from class: HttpReceiver

Method to be invoked when response content is available to be read.

This method takes care of ensuring the Content.Source passed to Response.ContentSourceListener.onContentSource(Response, Content.Source) calls the demand callback. The call to the demand callback is serialized with other events.

Overrides:

responseContentAvailable in class HttpReceiver

responseFailure

protected void responseFailure(Throwable failure,
 Promise<Boolean> promise)

Description copied from class: HttpReceiver

Method to be invoked when the response is failed.

This method takes care of notifying Response.FailureListeners.

Overrides:

responseFailure in class HttpReceiver

Parameters:

failure - the response failure