Package software.amazon.awssdk.services.s3.internal.checksums

Class ChecksumCalculatingInputStream

java.lang.Object

java.io.InputStream

java.io.FilterInputStream

software.amazon.awssdk.services.s3.internal.checksums.ChecksumCalculatingInputStream

All Implemented Interfaces:

Closeable, AutoCloseable

public class ChecksumCalculatingInputStream
extends FilterInputStream

Constructor Summary

Constructors

Constructor	Description
ChecksumCalculatingInputStream(InputStream in, SdkChecksum cksum)	Creates an input stream using the specified Checksum.

Method Summary

Modifier and Type	Method	Description
byte[]	getChecksumBytes()
int	read()	Reads from the underlying stream.
int	read(byte[] buf, int off, int len)	Reads up to len bytes at a time from the input stream, updates the checksum.
void	reset()	Resets stream state, including the running checksum.

Methods inherited from class java.io.FilterInputStream

available, close, mark, markSupported, read, skip

Methods inherited from class java.lang.Object

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

Constructor Details

ChecksumCalculatingInputStream

public ChecksumCalculatingInputStream(InputStream in,
 SdkChecksum cksum)

Creates an input stream using the specified Checksum.

Parameters:

in - the input stream to read

cksum - the Checksum implementation to use for computing the checksum

Method Details

read

public int read()
         throws IOException

Reads from the underlying stream. If the end of the stream is reached, the running checksum will be appended a byte at a time (1 per read call).

Overrides:

read in class FilterInputStream

Returns:

byte read, if eos has been reached, -1 will be returned.

Throws:

IOException

read

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

Reads up to len bytes at a time from the input stream, updates the checksum. If the end of the stream has been reached the checksum will be appended to the last 4 bytes.

Overrides:

read in class FilterInputStream

Parameters:

buf - buffer to write into

off - offset in the buffer to write to

len - maximum number of bytes to attempt to read.

Returns:

number of bytes written into buf, otherwise -1 will be returned to indicate eos.

Throws:

IOException

reset

public void reset()
           throws IOException

Resets stream state, including the running checksum.

Overrides:

reset in class FilterInputStream

Throws:

IOException

getChecksumBytes

public byte[] getChecksumBytes()