Package net.adoptopenjdk.icedteaweb.resources.downloader

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:

java.io.Closeable, java.lang.AutoCloseable

class NotifyingInputStream
extends CountingInputStream

Input stream which notifies a listener about its progress.

Field Summary

Fields

Modifier and Type	Field	Description
private java.util.function.Consumer<java.lang.Long>	downloadListener
(package private) static int	MAX_NOTIFICATIONS
(package private) static int	MIN_CHUNK_SIZE
private long	nextUpdateSize
(package private) static int	UNKNOWN_CHUNK_SIZE
private long	updateChunkSize

Fields inherited from class java.io.FilterInputStream

in

Constructor Summary

Constructors

Constructor	Description
NotifyingInputStream(java.io.InputStream inputStream, long totalSize, java.util.function.Consumer<java.lang.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 net.adoptopenjdk.icedteaweb.resources.downloader.CountingInputStream

mark, numBytesRead, reset, skip

Methods inherited from class java.io.FilterInputStream

available, close, markSupported, read

Methods inherited from class java.io.InputStream

nullInputStream, readAllBytes, readNBytes, readNBytes, transferTo

Methods inherited from class java.lang.Object

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

Field Detail

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 java.util.function.Consumer<java.lang.Long> downloadListener

updateChunkSize

private final long updateChunkSize

nextUpdateSize

private long nextUpdateSize

Constructor Detail

NotifyingInputStream

public NotifyingInputStream(java.io.InputStream inputStream,
                            long totalSize,
                            java.util.function.Consumer<java.lang.Long> downloadListener)

Method Detail

calculateChunkSize

private long calculateChunkSize(long totalSize)

read

public int read()
         throws java.io.IOException

Overrides:

read in class CountingInputStream

Throws:

java.io.IOException

read

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

Overrides:

read in class CountingInputStream

Throws:

java.io.IOException

handleRead

private void handleRead(long result)

notifyListener

private void notifyListener()