Class ChunkReader.StreamChunkIterator
- java.lang.Object
-
- org.openjdk.jmc.flightrecorder.util.ChunkReader.StreamChunkIterator
-
- All Implemented Interfaces:
java.util.Iterator<byte[]>
- Enclosing class:
- ChunkReader
private static class ChunkReader.StreamChunkIterator extends java.lang.Object implements java.util.Iterator<byte[]>
Iterator reading JFR chunks from a stream.
-
-
Field Summary
Fields Modifier and Type Field Description private java.io.DataInputStream
inputStream
private java.lang.Throwable
lastError
private ChunkReader.StreamState
streamState
-
Constructor Summary
Constructors Constructor Description StreamChunkIterator(java.io.InputStream inputStream)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method 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()
-
-
-
Field Detail
-
inputStream
private final java.io.DataInputStream inputStream
-
streamState
private ChunkReader.StreamState streamState
-
lastError
private java.lang.Throwable lastError
-
-
Method Detail
-
getDataStream
private java.io.DataInputStream getDataStream(java.io.InputStream is)
-
hasNext
public boolean hasNext()
- Specified by:
hasNext
in interfacejava.util.Iterator<byte[]>
-
validateJFRMagic
private boolean validateJFRMagic()
-
next
public byte[] next()
- Specified by:
next
in interfacejava.util.Iterator<byte[]>
-
retrieveNextChunk
private byte[] retrieveNextChunk() throws java.io.IOException
- Throws:
java.io.IOException
-
readBytesFromStream
private void readBytesFromStream(byte[] bytes, int offset, int count) throws java.io.IOException
- Throws:
java.io.IOException
-
remove
public void remove()
- Specified by:
remove
in interfacejava.util.Iterator<byte[]>
-
-