Package io.servicetalk.http.api

Interface HttpLifecycleObserver.HttpExchangeObserver

All Known Subinterfaces:

GrpcLifecycleObserver.GrpcExchangeObserver

Enclosing interface:

HttpLifecycleObserver

public static interface HttpLifecycleObserver.HttpExchangeObserver

An observer interface that provides visibility into events associated with a single HTTP exchange.

An exchange is represented by a request and a response. Both can be observed independently and may publish their events concurrently because connections are full-duplex. The terminal event for the exchange is signaled only when nested observers signal terminal events. Cancellation is the best effort, more events may be signaled after cancel.

Method Summary

Modifier and Type	Method	Description
void	onConnectionSelected(ConnectionInfo info)	Callback when a connection is selected for this exchange execution.
void	onExchangeFinally()	Callback when the exchange completes.
HttpLifecycleObserver.HttpRequestObserver	onRequest(HttpRequestMetaData requestMetaData)	Callback when a request starts.
HttpLifecycleObserver.HttpResponseObserver	onResponse(HttpResponseMetaData responseMetaData)	Callback when a response meta-data was observed.
void	onResponseCancel()	Callback if the response meta-data was cancelled.
void	onResponseError(Throwable cause)	Callback if the response meta-data was not received due to an error.

Method Details

onConnectionSelected

void onConnectionSelected(ConnectionInfo info)

Callback when a connection is selected for this exchange execution.

This callback may be invoked for every retry attempt.

Parameters:

info - ConnectionInfo of the selected connection

onRequest

HttpLifecycleObserver.HttpRequestObserver onRequest(HttpRequestMetaData requestMetaData)

Callback when a request starts.

Parameters:

requestMetaData - The corresponding HttpRequestMetaData

Returns:

an HttpLifecycleObserver.HttpRequestObserver that provides visibility into request events

onResponse

HttpLifecycleObserver.HttpResponseObserver onResponse(HttpResponseMetaData responseMetaData)

Callback when a response meta-data was observed.

Parameters:

responseMetaData - the corresponding HttpResponseMetaData

Returns:

an HttpLifecycleObserver.HttpResponseObserver that provides visibility into response events

onResponseError

void onResponseError(Throwable cause)

Callback if the response meta-data was not received due to an error.

Parameters:

cause - the cause of a response meta-data failure

onResponseCancel

void onResponseCancel()

Callback if the response meta-data was cancelled.

Cancellation is the best effort, more events may be signaled after cancel.

onExchangeFinally

void onExchangeFinally()

Callback when the exchange completes.

This is the final callback that is invoked after HttpLifecycleObserver.HttpRequestObserver terminate and either HttpLifecycleObserver.HttpResponseObserver terminate or onResponseError(Throwable)/onResponseCancel() method is invoked.