Package org.eclipse.jetty.client.internal

Class RequestContentAdapter

java.lang.Object

org.eclipse.jetty.client.internal.RequestContentAdapter

All Implemented Interfaces:

EventListener, Request.Content, Request.Content.Subscription, AsyncContentProvider.Listener, Callback, Invocable

public class RequestContentAdapter
extends Object
implements Request.Content, Request.Content.Subscription, AsyncContentProvider.Listener, Callback

Implements the conversion from ContentProvider to Request.Content.

Nested Class Summary

Nested classes/interfaces inherited from interface org.eclipse.jetty.util.Callback

Callback.Completable, Callback.Completing, Callback.Nested

Nested classes/interfaces inherited from interface org.eclipse.jetty.util.thread.Invocable

Invocable.InvocationType, Invocable.ReadyTask, Invocable.Task

Nested classes/interfaces inherited from interface org.eclipse.jetty.client.api.Request.Content

Request.Content.Consumer, Request.Content.Subscription

Field Summary

Fields inherited from interface org.eclipse.jetty.util.Callback

NOOP

Fields inherited from interface org.eclipse.jetty.util.thread.Invocable

__nonBlocking

Constructor Summary

Constructors

Constructor	Description
RequestContentAdapter(ContentProvider provider)

Method Summary

Modifier and Type	Method	Description
void	demand()	Demands more content, which eventually results in Request.Content.Consumer.onContent(ByteBuffer, boolean, Callback) to be invoked.
void	fail(Throwable failure)	Fails this request content, possibly failing and discarding accumulated content that was not demanded.
void	failed(Throwable x)	Callback invoked when the operation fails.
ContentProvider	getContentProvider()
String	getContentType()
Invocable.InvocationType	getInvocationType()
long	getLength()
boolean	isReproducible()	Whether this content producer can produce exactly the same content more than once.
void	onContent()	Callback method invoked when content is available
Request.Content.Subscription	subscribe(Request.Content.Consumer consumer, boolean emitInitialContent)	Initializes this content producer with the content consumer, and with the indication of whether initial content, if present, must be emitted upon the initial demand of content (to support delaying the send of the request content in case of Expect: 100-Continue when emitInitialContent is false).
void	succeeded()	Callback invoked when the operation completes.
String	toString()

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.eclipse.jetty.util.Callback

completeWith

Constructor Details

RequestContentAdapter

public RequestContentAdapter(ContentProvider provider)

Method Details

getContentProvider

public ContentProvider getContentProvider()

getContentType

public String getContentType()

Specified by:

getContentType in interface Request.Content

Returns:

the content type string such as "application/octet-stream" or "application/json;charset=UTF8", or null if no content type must be set

getLength

public long getLength()

Specified by:

getLength in interface Request.Content

Returns:

the content length, if known, or -1 if the content length is unknown

isReproducible

public boolean isReproducible()

Description copied from interface: Request.Content

Whether this content producer can produce exactly the same content more than once.

Implementations should return true only if the content can be produced more than once, which means that Request.Content.subscribe(Consumer, boolean) may be called again.

The HttpClient implementation may use this method in particular cases where it detects that it is safe to retry a request that failed.

Specified by:

isReproducible in interface Request.Content

Returns:

whether the content can be produced more than once

subscribe

public Request.Content.Subscription subscribe(Request.Content.Consumer consumer,
 boolean emitInitialContent)

Description copied from interface: Request.Content

Initializes this content producer with the content consumer, and with the indication of whether initial content, if present, must be emitted upon the initial demand of content (to support delaying the send of the request content in case of Expect: 100-Continue when emitInitialContent is false).

Specified by:

subscribe in interface Request.Content

Parameters:

consumer - the content consumer to invoke when there is demand for content

emitInitialContent - whether to emit initial content, if present

Returns:

the Subscription that links this producer to the consumer

demand

public void demand()

Description copied from interface: Request.Content.Subscription

Demands more content, which eventually results in Request.Content.Consumer.onContent(ByteBuffer, boolean, Callback) to be invoked.

Specified by:

demand in interface Request.Content.Subscription

fail

public void fail(Throwable failure)

Description copied from interface: Request.Content

Fails this request content, possibly failing and discarding accumulated content that was not demanded.

The failure may be notified to the consumer at a later time, when the consumer demands for content.

Typical failure: the request being aborted by user code, or idle timeouts.

Specified by:

fail in interface Request.Content

Specified by:

fail in interface Request.Content.Subscription

Parameters:

failure - the reason of the failure

onContent

public void onContent()

Description copied from interface: AsyncContentProvider.Listener

Callback method invoked when content is available

Specified by:

onContent in interface AsyncContentProvider.Listener

succeeded

public void succeeded()

Description copied from interface: Callback

Callback invoked when the operation completes.

Specified by:

succeeded in interface Callback

See Also:

• Callback.failed(Throwable)

failed

public void failed(Throwable x)

Description copied from interface: Callback

Callback invoked when the operation fails.

Specified by:

failed in interface Callback

Parameters:

x - the reason for the operation failure

getInvocationType

public Invocable.InvocationType getInvocationType()

Specified by:

getInvocationType in interface Invocable

Returns:

The InvocationType of this object

toString

public String toString()

Overrides:

toString in class Object