Class Crc32ChecksumValidatingInputStream

java.lang.Object

java.io.InputStream

java.io.FilterInputStream

software.amazon.awssdk.core.io.SdkFilterInputStream

software.amazon.awssdk.core.internal.util.Crc32ChecksumValidatingInputStream

All Implemented Interfaces:

Closeable, AutoCloseable, Releasable

@SdkInternalApi
public class Crc32ChecksumValidatingInputStream
extends SdkFilterInputStream

Wraps the provided input stream with a Crc32ChecksumCalculatingInputStream and after the stream is closed will validate the calculated checksum against the actual checksum.

Constructor Summary

Constructors

Constructor	Description
Crc32ChecksumValidatingInputStream(InputStream in, long expectedChecksum)

Method Summary

Modifier and Type	Method	Description
void	close()	Closes the underlying stream and validates the calculated checksum against the expected.
int	read()
int	read(byte[] b, int off, int len)

Methods inherited from class software.amazon.awssdk.core.io.SdkFilterInputStream

available, mark, markSupported, release, reset, skip

Methods inherited from class java.io.FilterInputStream

read

Methods inherited from class java.lang.Object

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

Constructor Details

Crc32ChecksumValidatingInputStream

public Crc32ChecksumValidatingInputStream(InputStream in,
 long expectedChecksum)

Parameters:

in - Input stream to content.

expectedChecksum - Expected CRC32 checksum returned by the service.

Method Details

close

public void close()
           throws IOException

Closes the underlying stream and validates the calculated checksum against the expected.

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

Overrides:

close in class SdkFilterInputStream

Throws:

Crc32MismatchException - If the calculated CRC32 checksum does not match the expected.

IOException

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