Package org.eclipse.jetty.io.content

Class ContentSinkSubscriber

java.lang.Object

org.eclipse.jetty.io.content.ContentSinkSubscriber

All Implemented Interfaces:

Flow.Subscriber<Content.Chunk>

public class ContentSinkSubscriber
extends Object
implements Flow.Subscriber<Content.Chunk>

A Flow.Subscriber that wraps a Content.Sink.

Content delivered to the onNext(Content.Chunk) method is written to Content.Sink.write(boolean, ByteBuffer, Callback) and the chunk is released once the write callback is succeeded or failed.

Constructor Summary

Constructors

Constructor	Description
ContentSinkSubscriber(Content.Sink sink, Callback callback)

Method Summary

Modifier and Type	Method	Description
void	onComplete()
void	onError(Throwable failure)
void	onNext(Content.Chunk chunk)
void	onSubscribe(Flow.Subscription subscription)

Methods inherited from class java.lang.Object

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

Constructor Details

ContentSinkSubscriber

public ContentSinkSubscriber(Content.Sink sink,
 Callback callback)

Method Details

onSubscribe

public void onSubscribe(Flow.Subscription subscription)

Specified by:

onSubscribe in interface Flow.Subscriber<Content.Chunk>

onNext

public void onNext(Content.Chunk chunk)

Specified by:

onNext in interface Flow.Subscriber<Content.Chunk>

onError

public void onError(Throwable failure)

Specified by:

onError in interface Flow.Subscriber<Content.Chunk>

onComplete

public void onComplete()

Specified by:

onComplete in interface Flow.Subscriber<Content.Chunk>