Modifier and Type	Class and Description
private class	AdapterRequestContent.Bridge A bridge between the `Request.Content` read by the `HttpClient` implementation and the `ReactiveRequest.Content` provided by applications.

Modifier and Type	Field and Description
private AdapterRequestContent.Bridge	bridge
private static final Logger	logger
private final ReactiveRequest.Content	reactiveContent

Access	Constructor and Description
public	AdapterRequestContent(ReactiveRequest.Content content)

Method Summary

Modifier and Type	Method and Description
public void	demand(Runnable the demand callback to invoke where there is a content chunk available runnable) Implements org.eclipse.jetty.io.Content.Source.demand. Demands to invoke the given demand callback parameter when a chunk of content is available.
public void	fail(Throwable the cause of the failure failure) Implements org.eclipse.jetty.io.Content.Source.fail. Fails this content source with a `last` `failure chunk`, failing and discarding accumulated content chunks that were not yet read.
public String	getContentType() Overrides default org.eclipse.jetty.client.Request.Content.getContentType.
public long	getLength() Overrides default org.eclipse.jetty.io.Content.Source.getLength.
private AdapterRequestContent.Bridge	getOrCreateBridge()
public Content.Chunk	read() Implements org.eclipse.jetty.io.Content.Source.read. Reads a chunk of content.
public boolean	rewind() Overrides default org.eclipse.jetty.io.Content.Source.rewind. Rewinds this content, if possible, so that subsequent reads return chunks starting from the beginning of this content.
public String	toString() Overrides java.lang.Object.toString. Returns a string representation of the object.

Inherited from java.lang.Object:: clone equals finalize getClass hashCode notify notifyAll wait wait wait

Field Detail

bridge	back to summary
private AdapterRequestContent.Bridge bridge

logger	back to summary
private static final Logger logger

reactiveContent	back to summary
private final ReactiveRequest.Content reactiveContent

Constructor Detail

AdapterRequestContent	back to summary
public AdapterRequestContent(ReactiveRequest.Content content)

Method Detail

demand back to summary

demand	back to summary
public void demand(Runnable runnable) Implements org.eclipse.jetty.io.Content.Source.demand. Doc from org.eclipse.jetty.io.Content.Source.demand. Demands to invoke the given demand callback parameter when a chunk of content is available. See how to use this method idiomatically. Implementations guarantee that calls to this method are safely reentrant so that stack overflows are avoided in the case of mutual recursion between the execution of the `Runnable` callback and a call to this method. Invocations of the passed `Runnable` are serialized and a callback for `demand` call is not invoked until any previous `demand` callback has returned. Thus the `Runnable` should not block waiting for a callback of a future demand call. The demand callback may be invoked spuriously: a subsequent call to `read()` may return `null`. Calling this method establishes a pending demand, which is fulfilled when the demand callback is invoked. Calling this method when there is already a pending demand results in an `IllegalStateException` to be thrown. If the invocation of the demand callback throws an exception, then `fail(Throwable)` is called. Parameters runnable:Runnable the demand callback to invoke where there is a content chunk available Annotations @Override

public void demand(Runnable runnable)

Implements org.eclipse.jetty.io.Content.Source.demand.

Doc from org.eclipse.jetty.io.Content.Source.demand.

Demands to invoke the given demand callback parameter when a chunk of content is available.

See how to use this method idiomatically.

Implementations guarantee that calls to this method are safely reentrant so that stack overflows are avoided in the case of mutual recursion between the execution of the Runnable callback and a call to this method. Invocations of the passed Runnable are serialized and a callback for demand call is not invoked until any previous demand callback has returned. Thus the Runnable should not block waiting for a callback of a future demand call.

The demand callback may be invoked spuriously: a subsequent call to read() may return null.

Calling this method establishes a pending demand, which is fulfilled when the demand callback is invoked.

Calling this method when there is already a pending demand results in an IllegalStateException to be thrown.

If the invocation of the demand callback throws an exception, then fail(Throwable) is called.

Parameters

runnable:Runnable: the demand callback to invoke where there is a content chunk available

Annotations

@Override

fail back to summary

fail	back to summary
public void fail(Throwable failure) Implements org.eclipse.jetty.io.Content.Source.fail. Doc from org.eclipse.jetty.io.Content.Source.fail. Fails this content source with a `last` `failure chunk`, failing and discarding accumulated content chunks that were not yet read. The failure may be notified to the content reader at a later time, when the content reader reads a content chunk, via a `Chunk` instance with a non null `Chunk#getFailure()`. If `read()` has returned a last chunk, this is a no operation. Typical failure: the content being aborted by user code, or idle timeouts. If this method has already been called, then it is a no operation. Parameters failure:Throwable the cause of the failure Annotations @Override

public void fail(Throwable failure)

Implements org.eclipse.jetty.io.Content.Source.fail.

Doc from org.eclipse.jetty.io.Content.Source.fail.

Fails this content source with a last failure chunk, failing and discarding accumulated content chunks that were not yet read.

The failure may be notified to the content reader at a later time, when the content reader reads a content chunk, via a Chunk instance with a non null Chunk#getFailure().

If read() has returned a last chunk, this is a no operation.

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

If this method has already been called, then it is a no operation.

Parameters

failure:Throwable: the cause of the failure

Annotations

@Override

getContentType back to summary

getContentType	back to summary
public String getContentType() Overrides default org.eclipse.jetty.client.Request.Content.getContentType. Returns:String Doc from org.eclipse.jetty.client.Request.Content.getContentType. the content type string such as "application/octet-stream" or "application/json;charset=UTF8", or null if the `Content-Type` header must not be set Annotations @Override

public String getContentType()

Overrides default org.eclipse.jetty.client.Request.Content.getContentType.

Returns:String

Doc from org.eclipse.jetty.client.Request.Content.getContentType.

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

Annotations

@Override

getLength	back to summary
public long getLength() Overrides default org.eclipse.jetty.io.Content.Source.getLength. Returns:long Doc from org.eclipse.jetty.io.Content.Source.getLength. the content length, if known, or -1 if the content length is unknown Annotations @Override

getLength

back to summary

public long getLength()

Overrides default org.eclipse.jetty.io.Content.Source.getLength.

Returns:long

Doc from org.eclipse.jetty.io.Content.Source.getLength.

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

Annotations

@Override

getOrCreateBridge	back to summary
private AdapterRequestContent.Bridge getOrCreateBridge()

read back to summary

read	back to summary
public Content.Chunk read() Implements org.eclipse.jetty.io.Content.Source.read. Doc from org.eclipse.jetty.io.Content.Source.read. Reads a chunk of content. See how to use this method idiomatically. The returned chunk could be: `null`, to signal that there isn't a chunk of content available an `Chunk` instance with non null `Chunk#getFailure()`, to signal that there was a failure trying to produce a chunk of content, or that the content production has been `failed` externally a `Chunk` instance, containing the chunk of content. Once a read returns an `Chunk` instance with non-null `Chunk#getFailure()` then if the failure is `last` further reads will continue to return the same failure chunk instance, otherwise further `read()` operations may return different non-failure chunks. Once a read returns a `last chunk`, further reads will continue to return a last chunk (although the instance may be different). The content reader code must ultimately arrange for a call to `Chunk#release()` on the returned `Chunk`. Additionally, prior to the ultimate call to `Chunk#release()`, the reader code may make additional calls to `Chunk#retain()`, that must ultimately be matched by a correspondent number of calls to `Chunk#release()`. Concurrent reads from different threads are not recommended, as they are inherently in a race condition. Reads performed outside the invocation context of a `demand callback` are allowed. However, reads performed with a pending demand are inherently in a race condition (the thread that reads with the thread that invokes the demand callback). Returns:Content.Chunk a chunk of content, possibly a failure instance, or `null` Annotations @Override

public Content.Chunk read()

Implements org.eclipse.jetty.io.Content.Source.read.

Doc from org.eclipse.jetty.io.Content.Source.read.

Reads a chunk of content.

See how to use this method idiomatically.

The returned chunk could be:

null, to signal that there isn't a chunk of content available
an Chunk instance with non null Chunk#getFailure(), to signal that there was a failure trying to produce a chunk of content, or that the content production has been failed externally
a Chunk instance, containing the chunk of content.

Once a read returns an Chunk instance with non-null Chunk#getFailure() then if the failure is last further reads will continue to return the same failure chunk instance, otherwise further read() operations may return different non-failure chunks.

Once a read returns a last chunk, further reads will continue to return a last chunk (although the instance may be different).

The content reader code must ultimately arrange for a call to Chunk#release() on the returned Chunk.

Additionally, prior to the ultimate call to Chunk#release(), the reader code may make additional calls to Chunk#retain(), that must ultimately be matched by a correspondent number of calls to Chunk#release().

Concurrent reads from different threads are not recommended, as they are inherently in a race condition.

Reads performed outside the invocation context of a demand callback are allowed. However, reads performed with a pending demand are inherently in a race condition (the thread that reads with the thread that invokes the demand callback).

Returns:Content.Chunk

a chunk of content, possibly a failure instance, or null

Annotations

@Override

rewind	back to summary
public boolean rewind() Overrides default org.eclipse.jetty.io.Content.Source.rewind. Doc from org.eclipse.jetty.io.Content.Source.rewind. Rewinds this content, if possible, so that subsequent reads return chunks starting from the beginning of this content. Returns:boolean true if this content has been rewound, false if this content cannot be rewound Annotations @Override

rewind

back to summary

public boolean rewind()

Overrides default org.eclipse.jetty.io.Content.Source.rewind.

Doc from org.eclipse.jetty.io.Content.Source.rewind.

Rewinds this content, if possible, so that subsequent reads return chunks starting from the beginning of this content.

Returns:boolean

true if this content has been rewound, false if this content cannot be rewound

Annotations

@Override

toString	back to summary
public String toString() Overrides java.lang.Object.toString. Doc from java.lang.Object.toString. Returns a string representation of the object. Returns:String a string representation of the object. Annotations @Override

toString

back to summary

public String toString()

Overrides java.lang.Object.toString.

Doc from java.lang.Object.toString.

Returns a string representation of the object.

Returns:String

a string representation of the object.

Annotations

@Override

org.eclipse.jetty.reactive.client.internal back to summary

private Class AdapterRequestContent.Bridge

Class Inheritance

extends Object
implements Subscriber<Content.Chunk>

java.lang.Object
org.eclipse.jetty.reactive.client.internal.AdapterRequestContent.Bridge

All Implemented Interfaces

org.reactivestreams.Subscriber

A bridge between the Request.Content read by the HttpClient implementation and the ReactiveRequest.Content provided by applications.

The first access to the Request.Content from the HttpClient implementation creates the bridge and forwards the access to it, calling either read() or demand(Runnable). Method read() returns the current Content.Chunk. Method demand(Runnable) forwards the demand to the ReactiveRequest.Content, which in turns calls onNext(Content.Chunk), providing the current chunk returned by read().

Field Summary

Modifier and Type	Field and Description
private Content.Chunk	chunk
private boolean	complete
private Runnable	demand
private Throwable	failure
private final SerializedInvoker	invoker
private final AutoLock	lock
private Subscription	subscription

Constructor Summary

Access	Constructor and Description
private	Bridge()

Method Summary

Modifier and Type	Method and Description
private void	demand(Runnable onDemand)
private void	fail(Throwable cause)
private void	invokeDemand(Runnable demand)
public void	onComplete() Implements org.reactivestreams.Subscriber.onComplete. Successful terminal state.
public void	onError(Throwable the throwable signaled error) Implements org.reactivestreams.Subscriber.onError. Failed terminal state.
public void	onNext(Content.Chunk the element signaled c) Implements org.reactivestreams.Subscriber.onNext. Data notification sent by the `Publisher` in response to requests to `Subscription#request(long)`.
public void	onSubscribe(Subscription the `Subscription` that allows requesting data via `Subscription#request(long)` s) Implements org.reactivestreams.Subscriber.onSubscribe. Invoked after calling `Publisher#subscribe(Subscriber)`.
private Content.Chunk	read()
public String	toString() Overrides java.lang.Object.toString. Returns a string representation of the object.

Inherited from java.lang.Object:: clone equals finalize getClass hashCode notify notifyAll wait wait wait

Field Detail

chunk	back to summary
private Content.Chunk chunk

complete	back to summary
private boolean complete

demand	back to summary
private Runnable demand

failure	back to summary
private Throwable failure

invoker	back to summary
private final SerializedInvoker invoker

lock	back to summary
private final AutoLock lock

subscription	back to summary
private Subscription subscription

Constructor Detail

Bridge	back to summary
private Bridge()

Method Detail

demand	back to summary
private void demand(Runnable onDemand)

fail	back to summary
private void fail(Throwable cause)

invokeDemand	back to summary
private void invokeDemand(Runnable demand)

onComplete back to summary

onComplete	back to summary
public void onComplete() Implements org.reactivestreams.Subscriber.onComplete. Doc from org.reactivestreams.Subscriber.onComplete. Successful terminal state. No further events will be sent even if `Subscription#request(long)` is invoked again. Annotations @Override

public void onComplete()

Implements org.reactivestreams.Subscriber.onComplete.

Doc from org.reactivestreams.Subscriber.onComplete.

Successful terminal state.

No further events will be sent even if Subscription#request(long) is invoked again.

Annotations

@Override

onError back to summary

onError	back to summary
public void onError(Throwable error) Implements org.reactivestreams.Subscriber.onError. Doc from org.reactivestreams.Subscriber.onError. Failed terminal state. No further events will be sent even if `Subscription#request(long)` is invoked again. Parameters error:Throwable the throwable signaled Annotations @Override

public void onError(Throwable error)

Implements org.reactivestreams.Subscriber.onError.

Doc from org.reactivestreams.Subscriber.onError.

Failed terminal state.

No further events will be sent even if Subscription#request(long) is invoked again.

Parameters

error:Throwable: the throwable signaled

Annotations

@Override

onNext back to summary

onNext	back to summary
public void onNext(Content.Chunk c) Implements org.reactivestreams.Subscriber.onNext. Doc from org.reactivestreams.Subscriber.onNext. Data notification sent by the `Publisher` in response to requests to `Subscription#request(long)`. Parameters c:Content.Chunk the element signaled Annotations @Override

public void onNext(Content.Chunk c)

Implements org.reactivestreams.Subscriber.onNext.

Doc from org.reactivestreams.Subscriber.onNext.

Data notification sent by the Publisher in response to requests to Subscription#request(long).

Parameters

c:Content.Chunk: the element signaled

Annotations

@Override

onSubscribe back to summary

onSubscribe	back to summary
public void onSubscribe(Subscription s) Implements org.reactivestreams.Subscriber.onSubscribe. Doc from org.reactivestreams.Subscriber.onSubscribe. Invoked after calling `Publisher#subscribe(Subscriber)`. No data will start flowing until `Subscription#request(long)` is invoked. It is the responsibility of this `Subscriber` instance to call `Subscription#request(long)` whenever more data is wanted. The `Publisher` will send notifications only in response to `Subscription#request(long)`. Parameters s:Subscription the `Subscription` that allows requesting data via `Subscription#request(long)` Annotations @Override

public void onSubscribe(Subscription s)

Implements org.reactivestreams.Subscriber.onSubscribe.

Doc from org.reactivestreams.Subscriber.onSubscribe.

Invoked after calling Publisher#subscribe(Subscriber).

No data will start flowing until Subscription#request(long) is invoked.

It is the responsibility of this Subscriber instance to call Subscription#request(long) whenever more data is wanted.

The Publisher will send notifications only in response to Subscription#request(long).

Parameters

s:Subscription: the Subscription that allows requesting data via Subscription#request(long)

Annotations

@Override

read	back to summary
private Content.Chunk read()

toString	back to summary
public String toString() Overrides java.lang.Object.toString. Doc from java.lang.Object.toString. Returns a string representation of the object. Returns:String a string representation of the object. Annotations @Override

toString

back to summary

public String toString()

Overrides java.lang.Object.toString.

Doc from java.lang.Object.toString.

Returns a string representation of the object.

Returns:String

a string representation of the object.

Annotations

@Override

public Class AdapterRequestContent

Nested and Inner Type Summary

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail

private Class AdapterRequestContent.Bridge

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail