com.ibm.cos.v2.core.internal.metrics

Class BytesReadTrackingPublisher

java.lang.Object

com.ibm.cos.v2.core.internal.metrics.BytesReadTrackingPublisher

All Implemented Interfaces:

org.reactivestreams.Publisher<ByteBuffer>

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

Publisher that tracks how many bytes are published from the wrapped publisher to the downstream subscriber.

Constructor Summary

Constructors

Constructor and Description
BytesReadTrackingPublisher(org.reactivestreams.Publisher<ByteBuffer> upstream, AtomicLong bytesRead)

Method Summary

Modifier and Type	Method and Description
long	bytesRead()
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

BytesReadTrackingPublisher

public BytesReadTrackingPublisher(org.reactivestreams.Publisher<ByteBuffer> upstream,
                                  AtomicLong bytesRead)

Method Detail

subscribe

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

Specified by:

subscribe in interface org.reactivestreams.Publisher<ByteBuffer>

bytesRead

public long bytesRead()