Package org.eclipse.jetty.io.content

Class ContentSourcePublisher

java.lang.Object

org.eclipse.jetty.io.content.ContentSourcePublisher

All Implemented Interfaces:

Flow.Publisher<Content.Chunk>

public class ContentSourcePublisher
extends Object
implements Flow.Publisher<Content.Chunk>

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.

Content.Source can be consumed only once and does not support multicast subscription. Content.Source will be consumed fully, otherwise will be failed in case of any errors to prevent resource leaks.

Constructor Summary

Constructors

Constructor	Description
ContentSourcePublisher(Content.Source content)

Method Summary

Modifier and Type	Method	Description
void	subscribe(Flow.Subscriber<? super Content.Chunk> subscriber)

Methods inherited from class java.lang.Object

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

Constructor Details

ContentSourcePublisher

public ContentSourcePublisher(Content.Source content)

Method Details

subscribe

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

Specified by:

subscribe in interface Flow.Publisher<Content.Chunk>