Package org.openjdk.jmc.flightrecorder.util

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

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()

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.util.Iterator

forEachRemaining

Field Detail

inputStream

private final java.io.DataInputStream inputStream

streamState

private ChunkReader.StreamState streamState

lastError

private java.lang.Throwable lastError

Constructor Detail

StreamChunkIterator

public StreamChunkIterator(java.io.InputStream inputStream)

Method Detail

getDataStream

private java.io.DataInputStream getDataStream(java.io.InputStream is)

hasNext

public boolean hasNext()

Specified by:

hasNext in interface java.util.Iterator<byte[]>

validateJFRMagic

private boolean validateJFRMagic()

next

public byte[] next()

Specified by:

next in interface java.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 interface java.util.Iterator<byte[]>