Class NotifyingInputStream

java.lang.Object

java.io.InputStream

java.io.FilterInputStream

net.adoptopenjdk.icedteaweb.resources.downloader.CountingInputStream

net.adoptopenjdk.icedteaweb.resources.downloader.NotifyingInputStream

All Implemented Interfaces:

Closeable, AutoCloseable

class NotifyingInputStream
extends CountingInputStream

Input stream which notifies a listener about its progress.

Field Summary

Fields

Modifier and Type	Field	Description
private final Consumer<Long>	downloadListener
(package private) static final int	MAX_NOTIFICATIONS
(package private) static final int	MIN_CHUNK_SIZE
private long	nextUpdateSize
(package private) static final int	UNKNOWN_CHUNK_SIZE
private final long	updateChunkSize

Fields inherited from class FilterInputStream

in

Constructor Summary

Constructors

Constructor	Description
NotifyingInputStream(InputStream inputStream, long totalSize, Consumer<Long> downloadListener)

Method Summary

Modifier and Type	Method	Description
private long	calculateChunkSize(long totalSize)
private void	handleRead(long result)
private void	notifyListener()
int	read()
int	read(byte[] b, int off, int len)

Methods inherited from class CountingInputStream

mark, numBytesRead, reset, skip

Methods inherited from class FilterInputStream

available, close, markSupported, read

Methods inherited from class InputStream

nullInputStream, readAllBytes, readNBytes, readNBytes, skipNBytes, transferTo

Methods inherited from class Object

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

Field Details

UNKNOWN_CHUNK_SIZE

static final int UNKNOWN_CHUNK_SIZE

See Also:

• Constant Field Values

MIN_CHUNK_SIZE

static final int MIN_CHUNK_SIZE

See Also:

• Constant Field Values

MAX_NOTIFICATIONS

static final int MAX_NOTIFICATIONS

See Also:

• Constant Field Values

downloadListener

private final Consumer<Long> downloadListener

updateChunkSize

private final long updateChunkSize

nextUpdateSize

private long nextUpdateSize

Constructor Details

NotifyingInputStream

public NotifyingInputStream(InputStream inputStream,
 long totalSize,
 Consumer<Long> downloadListener)

Method Details

calculateChunkSize

private long calculateChunkSize(long totalSize)

read

public int read()
         throws IOException

Overrides:

read in class CountingInputStream

Throws:

IOException

read

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

Overrides:

read in class CountingInputStream

Throws:

IOException

handleRead

private void handleRead(long result)

notifyListener

private void notifyListener()