com.ibm.cos.v2.http.auth.aws.eventstream.internal.io

Class TrailingDataFramePublisher

java.lang.Object

com.ibm.cos.v2.http.auth.aws.eventstream.internal.io.TrailingDataFramePublisher

All Implemented Interfaces:

org.reactivestreams.Publisher<ByteBuffer>

public final class TrailingDataFramePublisher
extends Object
implements org.reactivestreams.Publisher<ByteBuffer>

A publisher which wraps a publisher and appends a trailing frame once the wrapped publisher is finished.

Constructor Summary

Constructors

Constructor and Description
TrailingDataFramePublisher(org.reactivestreams.Publisher<ByteBuffer> publisher)

Method Summary

Modifier and Type	Method and Description
void	subscribe(org.reactivestreams.Subscriber<? super ByteBuffer> subscriber)

Methods inherited from class java.lang.Object

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

Constructor Detail

TrailingDataFramePublisher

public TrailingDataFramePublisher(org.reactivestreams.Publisher<ByteBuffer> publisher)

Method Detail

subscribe

public void subscribe(org.reactivestreams.Subscriber<? super ByteBuffer> subscriber)

Specified by:

subscribe in interface org.reactivestreams.Publisher<ByteBuffer>