BoundedSeekableByteChannelInputStream

java.lang.Object

java.io.InputStream

kala.compress.utils.BoundedArchiveInputStream

kala.compress.utils.BoundedSeekableByteChannelInputStream

All Implemented Interfaces:: Closeable, AutoCloseable

public class BoundedSeekableByteChannelInputStream extends BoundedArchiveInputStream

InputStream that delegates requests to the underlying SeekableByteChannel, making sure that only bytes from a certain range can be read.

Since:: 1.21

Field Summary

Fields

Modifier and Type

Field

Description

private final SeekableByteChannel

channel
Constructor Summary

Constructors

Constructor

Description

BoundedSeekableByteChannelInputStream(long start, long remaining, SeekableByteChannel channel)

Constructs a bounded stream on the underlying SeekableByteChannel
Method Summary

Modifier and Type

Method

Description

protected int

read(long pos, ByteBuffer buf)

Reads content of the stream into a ByteBuffer.

Methods inherited from class kala.compress.utils.BoundedArchiveInputStream
read, read

Methods inherited from class java.io.InputStream
available, close, mark, markSupported, nullInputStream, read, readAllBytes, readNBytes, readNBytes, reset, skip, skipNBytes, transferTo

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details
- channel
  
  private final SeekableByteChannel channel
Constructor Details
- BoundedSeekableByteChannelInputStream
  
  public BoundedSeekableByteChannelInputStream(long start, long remaining, SeekableByteChannel channel)
  
  Constructs a bounded stream on the underlying SeekableByteChannel
  
  Parameters:
  
  start - Position in the stream from where the reading of this bounded stream starts
  
  remaining - Amount of bytes which are allowed to read from the bounded stream
  
  channel - Channel which the reads will be delegated to
Method Details
- read
  
  protected int read(long pos, ByteBuffer buf) throws IOException
  
  Description copied from class: BoundedArchiveInputStream
  
  Reads content of the stream into a ByteBuffer.
  
  Specified by:
  
  read in class BoundedArchiveInputStream
  
  Parameters:
  
  pos - position to start the read.
  
  buf - buffer to add the read content.
  
  Returns:
  
  number of read bytes.
  
  Throws:
  
  IOException - if I/O fails.