Package kong.unirest.core
Class MonitoringInputStream
- java.lang.Object
-
- java.io.InputStream
-
- kong.unirest.core.MonitoringInputStream
-
- All Implemented Interfaces:
java.io.Closeable
,java.lang.AutoCloseable
public class MonitoringInputStream extends java.io.InputStream
-
-
Field Summary
Fields Modifier and Type Field Description private long
byteCount
private java.io.InputStream
content
private ProgressMonitor
downloadMonitor
private java.lang.String
fileName
private long
totalSize
-
Constructor Summary
Constructors Constructor Description MonitoringInputStream(java.io.InputStream content, ProgressMonitor downloadMonitor, java.lang.String fileName, RawResponse rawResponse)
MonitoringInputStream(java.io.InputStream content, ProgressMonitor downloadMonitor, java.nio.file.Path target, RawResponse rawResponse)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description int
available()
void
close()
private java.lang.Long
getBodySize(RawResponse r)
void
mark(int readlimit)
boolean
markSupported()
private void
monitor(int bytesRead)
int
read()
int
read(byte[] b)
int
read(byte[] b, int off, int len)
void
reset()
long
skip(long n)
private java.io.InputStream
wrap(java.io.InputStream is, RawResponse rawResponse)
-
-
-
Field Detail
-
content
private final java.io.InputStream content
-
downloadMonitor
private final ProgressMonitor downloadMonitor
-
totalSize
private final long totalSize
-
fileName
private final java.lang.String fileName
-
byteCount
private long byteCount
-
-
Constructor Detail
-
MonitoringInputStream
public MonitoringInputStream(java.io.InputStream content, ProgressMonitor downloadMonitor, java.nio.file.Path target, RawResponse rawResponse)
-
MonitoringInputStream
public MonitoringInputStream(java.io.InputStream content, ProgressMonitor downloadMonitor, java.lang.String fileName, RawResponse rawResponse)
-
-
Method Detail
-
wrap
private java.io.InputStream wrap(java.io.InputStream is, RawResponse rawResponse)
-
getBodySize
private java.lang.Long getBodySize(RawResponse r)
-
read
public int read() throws java.io.IOException
- Specified by:
read
in classjava.io.InputStream
- Throws:
java.io.IOException
-
read
public int read(byte[] b) throws java.io.IOException
- Overrides:
read
in classjava.io.InputStream
- Throws:
java.io.IOException
-
read
public int read(byte[] b, int off, int len) throws java.io.IOException
- Overrides:
read
in classjava.io.InputStream
- Throws:
java.io.IOException
-
monitor
private void monitor(int bytesRead)
-
close
public void close() throws java.io.IOException
- Specified by:
close
in interfacejava.lang.AutoCloseable
- Specified by:
close
in interfacejava.io.Closeable
- Overrides:
close
in classjava.io.InputStream
- Throws:
java.io.IOException
-
skip
public long skip(long n) throws java.io.IOException
- Overrides:
skip
in classjava.io.InputStream
- Throws:
java.io.IOException
-
available
public int available() throws java.io.IOException
- Overrides:
available
in classjava.io.InputStream
- Throws:
java.io.IOException
-
mark
public void mark(int readlimit)
- Overrides:
mark
in classjava.io.InputStream
-
markSupported
public boolean markSupported()
- Overrides:
markSupported
in classjava.io.InputStream
-
reset
public void reset() throws java.io.IOException
- Overrides:
reset
in classjava.io.InputStream
- Throws:
java.io.IOException
-
-