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

Class BytesReadTrackingInputStream

java.lang.Object

java.io.InputStream

java.io.FilterInputStream

com.ibm.cos.v2.core.io.SdkFilterInputStream

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

All Implemented Interfaces:

Releasable, Abortable, Closeable, AutoCloseable

public final class BytesReadTrackingInputStream
extends SdkFilterInputStream
implements Abortable

Field Summary

Fields inherited from class java.io.FilterInputStream

in

Constructor Summary

Constructors

Constructor and Description
BytesReadTrackingInputStream(AbortableInputStream in, AtomicLong bytesRead)

Method Summary

Modifier and Type	Method and Description
void	abort() Can be used to provide abortion logic prior to throwing the AbortedException.
long	bytesRead()
int	read()
int	read(byte[] b)
int	read(byte[] b, int off, int len)
long	skip(long n)

Methods inherited from class com.ibm.cos.v2.core.io.SdkFilterInputStream

abortIfNeeded, available, close, mark, markSupported, release, reset

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.ibm.cos.v2.core.internal.io.Releasable

release

Constructor Detail

BytesReadTrackingInputStream

public BytesReadTrackingInputStream(AbortableInputStream in,
                                    AtomicLong bytesRead)

Method Detail

bytesRead

public long bytesRead()

read

public int read()
         throws IOException

Overrides:

read in class SdkFilterInputStream

Throws:

IOException

read

public int read(byte[] b,
                int off,
                int len)
         throws IOException

Overrides:

read in class SdkFilterInputStream

Throws:

IOException

skip

public long skip(long n)
          throws IOException

Overrides:

skip in class SdkFilterInputStream

Throws:

IOException

read

public int read(byte[] b)
         throws IOException

Overrides:

read in class FilterInputStream

Throws:

IOException

abort

public void abort()

Description copied from class: SdkFilterInputStream

Can be used to provide abortion logic prior to throwing the AbortedException. No-op by default.

Specified by:

abort in interface Abortable

Overrides:

abort in class SdkFilterInputStream