Package com.puresoltechnologies.streaming.test

Class TestInputStream

java.lang.Object

java.io.InputStream

com.puresoltechnologies.streaming.streams.DelegatingInputStream

com.puresoltechnologies.streaming.streams.PositionInputStream

com.puresoltechnologies.streaming.test.TestInputStream

All Implemented Interfaces:

Closeable, AutoCloseable, Comparable<PositionInputStream>

public class TestInputStream
extends PositionInputStream

Constructor Summary

Constructors

Constructor	Description
TestInputStream(InputStream inputStream, long positionOffset, long triggerPosition, IOException ioException)
TestInputStream(InputStream inputStream, long positionOffset, long triggerPosition, RuntimeException runtimeException)
TestInputStream(InputStream inputStream, long triggerPosition, IOException ioException)
TestInputStream(InputStream inputStream, long triggerPosition, RuntimeException runtimeException)
TestInputStream(InputStream inputStream, long positionOffset, Duration duration, IOException ioException)
TestInputStream(InputStream inputStream, long positionOffset, Duration duration, RuntimeException runtimeException)
TestInputStream(InputStream inputStream, Duration duration, IOException ioException)
TestInputStream(InputStream inputStream, Duration duration, RuntimeException runtimeException)

Method Summary

Modifier and Type	Method	Description
boolean	equals(Object obj)
int	hashCode()
int	read()
int	read(byte[] b)
int	read(byte[] b, int off, int len)
long	skip(long n)	This method overrides the InputStream.skip(long) method to extend the contract of the method: This method tries to skip n bytes until the end of the stream or until an exception is thrown.

Methods inherited from class com.puresoltechnologies.streaming.streams.DelegatingInputStream

available, close, mark, markSupported, reset, toString

Methods inherited from class java.io.InputStream

readAllBytes, readNBytes, transferTo

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Methods inherited from class com.puresoltechnologies.streaming.streams.PositionInputStream

compareTo, getPosition, seek

Constructor Detail

TestInputStream

public TestInputStream(InputStream inputStream,
                       Duration duration,
                       RuntimeException runtimeException)

TestInputStream

public TestInputStream(InputStream inputStream,
                       Duration duration,
                       IOException ioException)

TestInputStream

public TestInputStream(InputStream inputStream,
                       long triggerPosition,
                       RuntimeException runtimeException)

TestInputStream

public TestInputStream(InputStream inputStream,
                       long triggerPosition,
                       IOException ioException)

TestInputStream

public TestInputStream(InputStream inputStream,
                       long positionOffset,
                       Duration duration,
                       RuntimeException runtimeException)

TestInputStream

public TestInputStream(InputStream inputStream,
                       long positionOffset,
                       Duration duration,
                       IOException ioException)

TestInputStream

public TestInputStream(InputStream inputStream,
                       long positionOffset,
                       long triggerPosition,
                       RuntimeException runtimeException)

TestInputStream

public TestInputStream(InputStream inputStream,
                       long positionOffset,
                       long triggerPosition,
                       IOException ioException)

Method Detail

read

public int read()
         throws IOException

Overrides:

read in class PositionInputStream

Throws:

IOException

read

public int read(byte[] b)
         throws IOException

Overrides:

read in class PositionInputStream

Throws:

IOException

read

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

Overrides:

read in class PositionInputStream

Throws:

IOException

skip

public long skip(long n)
          throws IOException

Description copied from class: DelegatingInputStream

This method overrides the InputStream.skip(long) method to extend the contract of the method:

• This method tries to skip n bytes until the end of the stream or until an exception is thrown. This fixes the strange behavior, that some input streams like BufferedInputStream only skip a certain amount of bytes (in this case until the end of the current buffer) with the first call. Subsequent calls skip more bytes later on. This is fixed here.
• The contract tells, that a negative number of bytes are skipped as zero bytes. This changes here and an IOException is thrown providing the hint, that the current input stream is not supporting back skips.

Overrides:

skip in class PositionInputStream

Parameters:

n - is the number bytes to skip.

Returns:

The actual number of bytes skipped are returned.

Throws:

IOException

hashCode

public int hashCode()

Overrides:

hashCode in class PositionInputStream

equals

public boolean equals(Object obj)

Overrides:

equals in class PositionInputStream