private static class ChunkReader.StreamChunkIterator
extends java.lang.Object
implements java.util.Iterator<byte[]>
Modifier and Type | Field and Description |
---|---|
private java.io.DataInputStream |
inputStream |
private java.lang.Throwable |
lastError |
private ChunkReader.StreamState |
streamState |
Constructor and Description |
---|
StreamChunkIterator(java.io.InputStream inputStream) |
Modifier and Type | Method and Description |
---|---|
private java.io.DataInputStream |
getDataStream(java.io.InputStream is) |
boolean |
hasNext() |
byte[] |
next() |
private void |
readBytesFromStream(byte[] bytes,
int offset,
int count) |
void |
remove() |
private byte[] |
retrieveNextChunk() |
private boolean |
validateJFRMagic() |
private final java.io.DataInputStream inputStream
private ChunkReader.StreamState streamState
private java.lang.Throwable lastError
private java.io.DataInputStream getDataStream(java.io.InputStream is)
public boolean hasNext()
hasNext
in interface java.util.Iterator<byte[]>
private boolean validateJFRMagic()
public byte[] next()
next
in interface java.util.Iterator<byte[]>
private byte[] retrieveNextChunk() throws java.io.IOException
java.io.IOException
private void readBytesFromStream(byte[] bytes, int offset, int count) throws java.io.IOException
java.io.IOException
public void remove()
remove
in interface java.util.Iterator<byte[]>