Class ReadableBuffers.BufferInputStream

java.lang.Object

java.io.InputStream

io.grpc.internal.ReadableBuffers.BufferInputStream

All Implemented Interfaces:

Detachable, HasByteBuffer, KnownLength, Closeable, AutoCloseable

Enclosing class:

ReadableBuffers

private static final class ReadableBuffers.BufferInputStream
extends InputStream
implements KnownLength, HasByteBuffer, Detachable

An InputStream that is backed by a ReadableBuffer.

Field Summary

Fields

Modifier and Type	Field	Description
private ReadableBuffer	buffer

Constructor Summary

Constructors

Constructor	Description
BufferInputStream(ReadableBuffer buffer)

Method Summary

Modifier and Type	Method	Description
int	available()	Returns the total number of bytes that can be read (or skipped over) from this object until all bytes have been read out.
boolean	byteBufferSupported()	Indicates whether or not HasByteBuffer.getByteBuffer() operation is supported.
void	close()
InputStream	detach()	Detaches the underlying data source from this instance and transfers to an InputStream.
ByteBuffer	getByteBuffer()	Gets a ByteBuffer containing some bytes of the content next to be read, or null if has reached end of the content.
void	mark(int readlimit)
boolean	markSupported()
int	read()
int	read(byte[] dest, int destOffset, int length)
void	reset()
long	skip(long n)

Methods inherited from class InputStream

read

Methods inherited from class Object

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

Field Details

buffer

private ReadableBuffer buffer

Constructor Details

BufferInputStream

public BufferInputStream(ReadableBuffer buffer)

Method Details

available

public int available()
              throws IOException

Description copied from interface: KnownLength

Returns the total number of bytes that can be read (or skipped over) from this object until all bytes have been read out.

Specified by:

available in interface KnownLength

Overrides:

available in class InputStream

Throws:

IOException

read

public int read()

Specified by:

read in class InputStream

read

public int read(byte[] dest,
 int destOffset,
 int length)
         throws IOException

Overrides:

read in class InputStream

Throws:

IOException

skip

public long skip(long n)
          throws IOException

Overrides:

skip in class InputStream

Throws:

IOException

mark

public void mark(int readlimit)

Overrides:

mark in class InputStream

reset

public void reset()
           throws IOException

Overrides:

reset in class InputStream

Throws:

IOException

markSupported

public boolean markSupported()

Overrides:

markSupported in class InputStream

byteBufferSupported

public boolean byteBufferSupported()

Description copied from interface: HasByteBuffer

Indicates whether or not HasByteBuffer.getByteBuffer() operation is supported.

Specified by:

byteBufferSupported in interface HasByteBuffer

getByteBuffer

@Nullable
public ByteBuffer getByteBuffer()

Description copied from interface: HasByteBuffer

Gets a ByteBuffer containing some bytes of the content next to be read, or null if has reached end of the content. The number of bytes contained in the returned buffer is implementation specific. Calling this method does not change the position of the input stream. The returned buffer's content should not be modified, but the position, limit, and mark may be changed. Operations for changing the position, limit, and mark of the returned buffer does not affect the position, limit, and mark of this input stream. This is an optional method, so callers should first check HasByteBuffer.byteBufferSupported().

Specified by:

getByteBuffer in interface HasByteBuffer

detach

public InputStream detach()

Description copied from interface: Detachable

Detaches the underlying data source from this instance and transfers to an InputStream. Detaching data from an already-detached instance gives an InputStream with zero bytes of data.

Specified by:

detach in interface Detachable

close

public void close()
           throws IOException

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

Overrides:

close in class InputStream

Throws:

IOException