Package io.deephaven.io.streams

Class BufferedChannelReader

java.lang.Object

io.deephaven.io.streams.BufferedChannelReader

public class BufferedChannelReader
extends Object

Constructor Summary

Constructors

Constructor	Description
BufferedChannelReader(String filename, int blockSize, int readSize)	Guarantees that each buffer from readNext() will have remaining() >= blockSize [that is, until it starts winding down on the end of the file] When it needs to refresh, it will read <= readSize from the channel

Method Summary

Modifier and Type	Method	Description
void	close()
ByteBuffer	getBb()
int	getRead()
ByteBuffer	readNext()

Methods inherited from class java.lang.Object

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

Constructor Details

BufferedChannelReader

public BufferedChannelReader(String filename,
 int blockSize,
 int readSize)

Guarantees that each buffer from readNext() will have remaining() >= blockSize [that is, until it starts winding down on the end of the file] When it needs to refresh, it will read <= readSize from the channel

Method Details

readNext

public ByteBuffer readNext()
                    throws IOException

Throws:

IOException

getBb

public ByteBuffer getBb()

getRead

public int getRead()

close

public void close()
           throws IOException

Throws:

IOException