Package com.helger.base.io.stream

Class LoggingInputStream

java.lang.Object

java.io.InputStream

java.io.FilterInputStream

com.helger.base.io.stream.WrappedInputStream

com.helger.base.io.stream.LoggingInputStream

All Implemented Interfaces:

Closeable, AutoCloseable

public class LoggingInputStream
extends WrappedInputStream

A wrapper around an InputStream that logs read and skip actions.

Author:

Philip Helger

Field Summary

Fields inherited from class java.io.FilterInputStream

in

Constructor Summary

Constructors

Constructor	Description
LoggingInputStream(@NonNull InputStream aSourceIS)

Method Summary

Modifier and Type	Method	Description
void	close()
final long	getPosition()
final void	mark(int nReadlimit)
protected void	onClose(long nCurrentPosition)
protected void	onMark(int nReadLimit, long nCurrentPosition)
protected void	onRead(int nBytesRead, long nNewPosition)
protected void	onReset(long nCurrentPosition)
protected void	onSkip(long nBytesSkipped, long nNewPosition)
final int	read()
final int	read(byte[] aBuf, int nOffset, int nLength)
final void	reset()
final long	skip(long n)
String	toString()

Methods inherited from class com.helger.base.io.stream.WrappedInputStream

getWrappedInputStream

Methods inherited from class java.io.FilterInputStream

available, markSupported, read

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, wait, wait, wait

Constructor Details

LoggingInputStream

public LoggingInputStream(@NonNull InputStream aSourceIS)

Parameters:

aSourceIS - The input stream to be logged. May not be null.

Method Details

getPosition

public final long getPosition()

Returns:

The current read position. Always ≥ 0.

onRead

@OverrideOnDemand
protected void onRead(int nBytesRead,
 long nNewPosition)

onSkip

@OverrideOnDemand
protected void onSkip(long nBytesSkipped,
 long nNewPosition)

onMark

@OverrideOnDemand
protected void onMark(int nReadLimit,
 long nCurrentPosition)

onReset

@OverrideOnDemand
protected void onReset(long nCurrentPosition)

onClose

@OverrideOnDemand
protected void onClose(long nCurrentPosition)

read

public final int read()
               throws IOException

Overrides:

read in class FilterInputStream

Throws:

IOException

read

public final int read(byte[] aBuf,
 int nOffset,
 int nLength)
               throws IOException

Overrides:

read in class FilterInputStream

Throws:

IOException

skip

public final long skip(@Nonnegative
 long n)
                throws IOException

Overrides:

skip in class FilterInputStream

Throws:

IOException

mark

public final void mark(@Nonnegative
 int nReadlimit)

Overrides:

mark in class FilterInputStream

reset

public final void reset()
                 throws IOException

Overrides:

reset in class FilterInputStream

Throws:

IOException

close

public void close()
           throws IOException

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

Overrides:

close in class FilterInputStream

Throws:

IOException

toString

public String toString()

Overrides:

toString in class WrappedInputStream