Wraps a Content.Source as a Flow.Publisher. When content is requested via Flow.Subscription#request(long), it is read from the passed Content.Source and passed to Flow.Subscriber#onNext(Object). If no content is available, then the Content.Source#demand(Runnable) method is used to ultimately call Flow.Subscriber#onNext(Object) once content is available.

Nested and Inner Type Summary

Modifier and Type	Class and Description
private static class	ContentSourcePublisher.SubscriptionImpl

Field Summary

Modifier and Type	Field and Description
private final Content.Source	content

Access	Constructor and Description
public	ContentSourcePublisher(Content.Source content)

Modifier and Type	Method and Description
public void	subscribe(Flow.Subscriber<? super Content.Chunk> the subscriber subscriber) Implements java.util.concurrent.Flow.Publisher.subscribe. Adds the given Subscriber if possible.

Field Detail

content	back to summary
private final Content.Source content

ContentSourcePublisher	back to summary
public ContentSourcePublisher(Content.Source content)

Method Detail

subscribe back to summary

subscribe	back to summary
public void subscribe(Flow.Subscriber<? super Content.Chunk> subscriber) Implements java.util.concurrent.Flow.Publisher.subscribe. Doc from java.util.concurrent.Flow.Publisher.subscribe. Adds the given Subscriber if possible. If already subscribed, or the attempt to subscribe fails due to policy violations or errors, the Subscriber's `onError` method is invoked with an `IllegalStateException`. Otherwise, the Subscriber's `onSubscribe` method is invoked with a new `Subscription`. Subscribers may enable receiving items by invoking the `request` method of this Subscription, and may unsubscribe by invoking its `cancel` method. Parameters subscriber:Flow.Subscriber<? super Content.Chunk> the subscriber Annotations @Override

public void subscribe(Flow.Subscriber<? super Content.Chunk> subscriber)

Implements java.util.concurrent.Flow.Publisher.subscribe.

Doc from java.util.concurrent.Flow.Publisher.subscribe.

Adds the given Subscriber if possible. If already subscribed, or the attempt to subscribe fails due to policy violations or errors, the Subscriber's onError method is invoked with an IllegalStateException. Otherwise, the Subscriber's onSubscribe method is invoked with a new Subscription. Subscribers may enable receiving items by invoking the request method of this Subscription, and may unsubscribe by invoking its cancel method.

Parameters

subscriber:Flow.Subscriber<? super Content.Chunk>: the subscriber

Annotations

@Override

org.eclipse.jetty.io.content back to summary

private Class ContentSourcePublisher.SubscriptionImpl

Class Inheritance

extends Object
implements Subscription

java.lang.Object
org.eclipse.jetty.io.content.ContentSourcePublisher.SubscriptionImpl

All Implemented Interfaces

java.util.concurrent.Flow.Subscription

Field Summary

Modifier and Type	Field and Description
private boolean	cancelled
private final Content.Source	content
private long	demand
private final AutoLock	lock
private boolean	stalled
private final Flow.Subscriber<? super Content.Chunk>	subscriber
private boolean	terminated

Constructor Summary

Access	Constructor and Description
public	SubscriptionImpl(Content.Source content, Flow.Subscriber<? super Content.Chunk> subscriber)

Method Summary

Modifier and Type	Method and Description
public void	cancel() Implements java.util.concurrent.Flow.Subscription.cancel. Causes the Subscriber to (eventually) stop receiving messages.
private void	process()
public void	request(long the increment of demand; a value of `Long.MAX_VALUE` may be considered as effectively unbounded n) Implements java.util.concurrent.Flow.Subscription.request. Adds the given number `n` of items to the current unfulfilled demand for this subscription.
private void	terminate()

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

Field Detail

cancelled	back to summary
private boolean cancelled

content	back to summary
private final Content.Source content

demand	back to summary
private long demand

lock	back to summary
private final AutoLock lock

stalled	back to summary
private boolean stalled

subscriber	back to summary
private final Flow.Subscriber<? super Content.Chunk> subscriber

terminated	back to summary
private boolean terminated

Constructor Detail

SubscriptionImpl	back to summary
public SubscriptionImpl(Content.Source content, Flow.Subscriber<? super Content.Chunk> subscriber)

Method Detail

cancel back to summary

cancel	back to summary
public void cancel() Implements java.util.concurrent.Flow.Subscription.cancel. Doc from java.util.concurrent.Flow.Subscription.cancel. Causes the Subscriber to (eventually) stop receiving messages. Implementation is best-effort -- additional messages may be received after invoking this method. A cancelled subscription need not ever receive an `onComplete` or `onError` signal. Annotations @Override

public void cancel()

Implements java.util.concurrent.Flow.Subscription.cancel.

Doc from java.util.concurrent.Flow.Subscription.cancel.

Causes the Subscriber to (eventually) stop receiving messages. Implementation is best-effort -- additional messages may be received after invoking this method. A cancelled subscription need not ever receive an onComplete or onError signal.

Annotations

@Override

process	back to summary
private void process()

request back to summary

request	back to summary
public void request(long n) Implements java.util.concurrent.Flow.Subscription.request. Doc from java.util.concurrent.Flow.Subscription.request. Adds the given number `n` of items to the current unfulfilled demand for this subscription. If `n` is less than or equal to zero, the Subscriber will receive an `onError` signal with an `IllegalArgumentException` argument. Otherwise, the Subscriber will receive up to `n` additional `onNext` invocations (or fewer if terminated). Parameters n:long the increment of demand; a value of `Long.MAX_VALUE` may be considered as effectively unbounded Annotations @Override

public void request(long n)

Implements java.util.concurrent.Flow.Subscription.request.

Doc from java.util.concurrent.Flow.Subscription.request.

Adds the given number n of items to the current unfulfilled demand for this subscription. If n is less than or equal to zero, the Subscriber will receive an onError signal with an IllegalArgumentException argument. Otherwise, the Subscriber will receive up to n additional onNext invocations (or fewer if terminated).

Parameters

n:long: the increment of demand; a value of Long.MAX_VALUE may be considered as effectively unbounded

Annotations

@Override

terminate	back to summary
private void terminate()

public Class ContentSourcePublisher

Nested and Inner Type Summary

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail

private Class ContentSourcePublisher.SubscriptionImpl

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail