Class StreamStore.Stream

java.lang.Object

java.io.InputStream

org.h2.mvstore.StreamStore.Stream

All Implemented Interfaces:

Closeable, AutoCloseable

Enclosing class:

StreamStore

static class StreamStore.Stream
extends InputStream

A stream backed by a map.

Field Summary

Fields

Modifier and Type	Field	Description
private ByteArrayInputStream	buffer
private ByteBuffer	idBuffer
private final long	length
private byte[]	oneByteBuffer
private long	pos
private long	skip
private final StreamStore	store

Constructor Summary

Constructors

Constructor	Description
Stream(StreamStore store, byte[] id)

Method Summary

Modifier and Type	Method	Description
void	close()
private ByteArrayInputStream	nextBuffer()
int	read()
int	read(byte[] b, int off, int len)
long	skip(long n)

Methods inherited from class InputStream

available, mark, markSupported, nullInputStream, read, readAllBytes, readNBytes, readNBytes, reset, skipNBytes, transferTo

Methods inherited from class Object

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

Field Details

store

private final StreamStore store

oneByteBuffer

private byte[] oneByteBuffer

idBuffer

private ByteBuffer idBuffer

buffer

private ByteArrayInputStream buffer

skip

private long skip

length

private final long length

pos

private long pos

Constructor Details

Stream

Stream(StreamStore store,
 byte[] id)

Method Details

read

public int read()
         throws IOException

Specified by:

read in class InputStream

Throws:

IOException

skip

public long skip(long n)

Overrides:

skip in class InputStream

close

public void close()

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

Overrides:

close in class InputStream

read

public int read(byte[] b,
 int off,
 int len)
         throws IOException

Overrides:

read in class InputStream

Throws:

IOException

nextBuffer

private ByteArrayInputStream nextBuffer()