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.

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>