Package org.ka2ddo.yaac.io

Class CountingInputStreamForSockets

java.lang.Object

java.io.InputStream

java.io.FilterInputStream

org.ka2ddo.yaac.io.CountingInputStreamForSockets

All Implemented Interfaces:

Closeable, AutoCloseable

public final class CountingInputStreamForSockets
extends FilterInputStream

InputStream to count the number of bytes read from the input, so as to drive a progress bar, but it avoids using the read() method of the passed-in InputStream, as SocketInputStream malloc's a 1-byte byte array for each such read, then throws the array away.

Author:

Andrew Pavlin, KA2DDO

Field Summary

Fields inherited from class java.io.FilterInputStream

in

Constructor Summary

Constructors

Constructor	Description
CountingInputStreamForSockets(InputStream in)	Create a CountingInputStream wrapped around the specified InputStream.

Method Summary

Modifier and Type	Method	Description
final long	getByteCount()	Get the number of bytes passed through this stream (so far).
void	mark(int readlimit)	Override mark to do nothing.
boolean	markSupported()	Override the markSupported operation.
final int	read()	Read a byte.
final int	read(byte[] b)	Read an array of bytes.
final int	read(byte[] b, int off, int len)	Read bytes into an offset array.
void	reset()	Override reset to reset the byte count.
final long	skip(long n)	Skip some bytes.

Methods inherited from class java.io.FilterInputStream

available, close

Methods inherited from class java.io.InputStream

nullInputStream, readAllBytes, readNBytes, readNBytes, skipNBytes, transferTo

Methods inherited from class java.lang.Object

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

Constructor Details

CountingInputStreamForSockets

public CountingInputStreamForSockets(InputStream in)

Create a CountingInputStream wrapped around the specified InputStream.

Parameters:

in - the InputStream to count.

Method Details

markSupported

public boolean markSupported()

Override the markSupported operation.

Overrides:

markSupported in class FilterInputStream

mark

public void mark(int readlimit)

Override mark to do nothing.

Overrides:

mark in class FilterInputStream

reset

public void reset()

Override reset to reset the byte count.

Overrides:

reset in class FilterInputStream

read

public final int read()
               throws IOException

Read a byte.

Overrides:

read in class FilterInputStream

Throws:

IOException

read

public final int read(byte[] b)
               throws IOException

Read an array of bytes.

Overrides:

read in class FilterInputStream

Throws:

IOException

read

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

Read bytes into an offset array.

Overrides:

read in class FilterInputStream

Throws:

IOException

skip

public final long skip(long n)
                throws IOException

Skip some bytes.

Overrides:

skip in class FilterInputStream

Throws:

IOException

getByteCount

public final long getByteCount()

Get the number of bytes passed through this stream (so far).

Returns:

the number of read bytes so far.