Top Fields Constructors Methods
org.eclipse.jetty.reactive.client.internal

public Class RequestEventPublisher

extends AbstractEventPublisher<ReactiveRequest.Event>
implements Listener
Class Inheritance
All Implemented Interfaces
org.eclipse.jetty.client.Request.Listener, org.eclipse.jetty.client.Request.FailureListener, org.eclipse.jetty.client.Request.RequestListener, java.util.EventListener, org.eclipse.jetty.client.Request.SuccessListener, org.eclipse.jetty.client.Request.ContentListener, org.eclipse.jetty.client.Request.CommitListener, org.eclipse.jetty.client.Request.HeadersListener, org.eclipse.jetty.client.Request.BeginListener, org.eclipse.jetty.client.Request.QueuedListener
Imports
java.nio.ByteBuffer, org.eclipse.jetty.client.Request, org.eclipse.jetty.reactive.client.ReactiveRequest

Field Summary

Modifier and TypeField and Description
private final ReactiveRequest
request

Constructor Summary

AccessConstructor and Description
public
RequestEventPublisher(ReactiveRequest request)

Method Summary

Modifier and TypeMethod and Description
public void
onBegin(Request
the request that begins being processed
request)

Overrides default org.eclipse.jetty.client.Request.Listener.onBegin.

Callback method invoked when the request begins being processed in order to be sent.
public void
onCommit(Request
the request that has been committed
request)

Overrides default org.eclipse.jetty.client.Request.Listener.onCommit.

Callback method invoked when the request headers (and perhaps small content) have been sent.
public void
onContent(Request
the request that has been committed
request, ByteBuffer
the content
content)

Overrides default org.eclipse.jetty.client.Request.Listener.onContent.

Callback method invoked when a chunk of request content has been sent successfully.
public void
onFailure(Request
the request that failed
request, Throwable
the failure
failure)

Overrides default org.eclipse.jetty.client.Request.Listener.onFailure.

Callback method invoked when the request has failed to be sent
public void
onHeaders(Request
the request that is about to be committed
request)

Overrides default org.eclipse.jetty.client.Request.Listener.onHeaders.

Callback method invoked when the request headers (and perhaps small content) are ready to be sent.
public void
onQueued(Request
the request being queued
request)

Overrides default org.eclipse.jetty.client.Request.Listener.onQueued.

Callback method invoked when the request is queued, waiting to be sent
public void
onSuccess(Request
the request sent
request)

Overrides default org.eclipse.jetty.client.Request.Listener.onSuccess.

Callback method invoked when the request has been successfully sent.
Inherited from org.eclipse.jetty.reactive.client.internal.AbstractEventPublisher:
emitfailonRequestsucceed

Field Detail

requestback to summary
private final ReactiveRequest request

Constructor Detail

RequestEventPublisherback to summary
public RequestEventPublisher(ReactiveRequest request)

Method Detail

onBeginback to summary
public void onBegin(Request request)

Overrides default org.eclipse.jetty.client.Request.Listener.onBegin.

Doc from org.eclipse.jetty.client.Request.BeginListener.onBegin.

Callback method invoked when the request begins being processed in order to be sent. This is the last opportunity to modify the request.

Parameters
request:Request

the request that begins being processed

Annotations
@Override
onCommitback to summary
public void onCommit(Request request)

Overrides default org.eclipse.jetty.client.Request.Listener.onCommit.

Doc from org.eclipse.jetty.client.Request.CommitListener.onCommit.

Callback method invoked when the request headers (and perhaps small content) have been sent. The request is now committed, and in transit to the server, and further modifications to the request may have no effect.

Parameters
request:Request

the request that has been committed

Annotations
@Override
onContentback to summary
public void onContent(Request request, ByteBuffer content)

Overrides default org.eclipse.jetty.client.Request.Listener.onContent.

Doc from org.eclipse.jetty.client.Request.ContentListener.onContent.

Callback method invoked when a chunk of request content has been sent successfully. Changes to bytes in the given buffer have no effect, as the content has already been sent.

Parameters
request:Request

the request that has been committed

content:ByteBuffer

the content

Annotations
@Override
onFailureback to summary
public void onFailure(Request request, Throwable failure)

Overrides default org.eclipse.jetty.client.Request.Listener.onFailure.

Doc from org.eclipse.jetty.client.Request.FailureListener.onFailure.

Callback method invoked when the request has failed to be sent

Parameters
request:Request

the request that failed

failure:Throwable

the failure

Annotations
@Override
onHeadersback to summary
public void onHeaders(Request request)

Overrides default org.eclipse.jetty.client.Request.Listener.onHeaders.

Doc from org.eclipse.jetty.client.Request.HeadersListener.onHeaders.

Callback method invoked when the request headers (and perhaps small content) are ready to be sent. The request has been converted into bytes, but not yet sent to the server, and further modifications to the request may have no effect.

Parameters
request:Request

the request that is about to be committed

Annotations
@Override
onQueuedback to summary
public void onQueued(Request request)

Overrides default org.eclipse.jetty.client.Request.Listener.onQueued.

Doc from org.eclipse.jetty.client.Request.QueuedListener.onQueued.

Callback method invoked when the request is queued, waiting to be sent

Parameters
request:Request

the request being queued

Annotations
@Override
onSuccessback to summary
public void onSuccess(Request request)

Overrides default org.eclipse.jetty.client.Request.Listener.onSuccess.

Doc from org.eclipse.jetty.client.Request.SuccessListener.onSuccess.

Callback method invoked when the request has been successfully sent.

Parameters
request:Request

the request sent

Annotations
@Override