Package io.grpc.internal
Class ReadableBuffers.ByteReadableBufferWrapper
- java.lang.Object
-
- io.grpc.internal.AbstractReadableBuffer
-
- io.grpc.internal.ReadableBuffers.ByteReadableBufferWrapper
-
- All Implemented Interfaces:
ReadableBuffer,java.io.Closeable,java.lang.AutoCloseable
- Enclosing class:
- ReadableBuffers
private static class ReadableBuffers.ByteReadableBufferWrapper extends AbstractReadableBuffer
AReadableBufferthat is backed by aByteBuffer.
-
-
Field Summary
Fields Modifier and Type Field Description (package private) java.nio.ByteBufferbytes
-
Constructor Summary
Constructors Constructor Description ByteReadableBufferWrapper(java.nio.ByteBuffer bytes)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description byte[]array()Gets the backing array for this buffer.intarrayOffset()Gets the offset in the backing array of the current read position.booleanbyteBufferSupported()Indicates whether or notReadableBuffer.getByteBuffer()operation is supported for this buffer.java.nio.ByteBuffergetByteBuffer()Gets aByteBufferthat contains some bytes of the content next to be read, ornullif this buffer has been exhausted.booleanhasArray()Indicates whether or not this buffer exposes a backing array.voidmark()Marks the current position in this buffer.booleanmarkSupported()Indicates whether or notReadableBuffer.mark()operation is supported for this buffer.intreadableBytes()Gets the current number of readable bytes remaining in this buffer.voidreadBytes(byte[] dest, int destOffset, int length)Readslengthbytes from this buffer and writes them to the destination array.ReadableBuffers.ByteReadableBufferWrapperreadBytes(int length)Readslengthbytes from this buffer and returns a new Buffer containing them.voidreadBytes(java.io.OutputStream dest, int length)Readslengthbytes from this buffer and writes them to the destination stream.voidreadBytes(java.nio.ByteBuffer dest)Reads from this buffer until the destination's position reaches its limit, and increases the read position by the number of the transferred bytes.intreadUnsignedByte()Reads the next unsigned byte from this buffer and increments the read position by 1.voidreset()Repositions this buffer to the position at the timeReadableBuffer.mark()was last called on this buffer.voidskipBytes(int length)Increments the read position by the given length.-
Methods inherited from class io.grpc.internal.AbstractReadableBuffer
checkReadable, close, readInt
-
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
-
Methods inherited from interface io.grpc.internal.ReadableBuffer
touch
-
-
-
-
Method Detail
-
readableBytes
public int readableBytes()
Description copied from interface:ReadableBufferGets the current number of readable bytes remaining in this buffer.
-
readUnsignedByte
public int readUnsignedByte()
Description copied from interface:ReadableBufferReads the next unsigned byte from this buffer and increments the read position by 1.
-
skipBytes
public void skipBytes(int length)
Description copied from interface:ReadableBufferIncrements the read position by the given length.
-
readBytes
public void readBytes(byte[] dest, int destOffset, int length)Description copied from interface:ReadableBufferReadslengthbytes from this buffer and writes them to the destination array. Increments the read position bylength.- Parameters:
dest- the destination array to receive the bytes.destOffset- the starting offset in the destination array.length- the number of bytes to be copied.
-
readBytes
public void readBytes(java.nio.ByteBuffer dest)
Description copied from interface:ReadableBufferReads from this buffer until the destination's position reaches its limit, and increases the read position by the number of the transferred bytes.- Parameters:
dest- the destination buffer to receive the bytes.
-
readBytes
public void readBytes(java.io.OutputStream dest, int length) throws java.io.IOExceptionDescription copied from interface:ReadableBufferReadslengthbytes from this buffer and writes them to the destination stream. Increments the read position bylength. If the required bytes are not readable, throwsIndexOutOfBoundsException.- Parameters:
dest- the destination stream to receive the bytes.length- the number of bytes to be copied.- Throws:
java.io.IOException- thrown if any error was encountered while writing to the stream.
-
readBytes
public ReadableBuffers.ByteReadableBufferWrapper readBytes(int length)
Description copied from interface:ReadableBufferReadslengthbytes from this buffer and returns a new Buffer containing them. Some implementations may return a Buffer sharing the backing memory with this buffer to prevent copying. However, that means that the returned buffer may keep the (possibly much larger) backing memory in use even after this buffer is closed.- Parameters:
length- the number of bytes to contain in returned Buffer.
-
hasArray
public boolean hasArray()
Description copied from interface:ReadableBufferIndicates whether or not this buffer exposes a backing array.- Specified by:
hasArrayin interfaceReadableBuffer- Overrides:
hasArrayin classAbstractReadableBuffer
-
array
public byte[] array()
Description copied from interface:ReadableBufferGets the backing array for this buffer. This is an optional method, so callers should first checkReadableBuffer.hasArray().- Specified by:
arrayin interfaceReadableBuffer- Overrides:
arrayin classAbstractReadableBuffer
-
arrayOffset
public int arrayOffset()
Description copied from interface:ReadableBufferGets the offset in the backing array of the current read position. This is an optional method, so callers should first checkReadableBuffer.hasArray()- Specified by:
arrayOffsetin interfaceReadableBuffer- Overrides:
arrayOffsetin classAbstractReadableBuffer
-
markSupported
public boolean markSupported()
Description copied from interface:ReadableBufferIndicates whether or notReadableBuffer.mark()operation is supported for this buffer.- Specified by:
markSupportedin interfaceReadableBuffer- Overrides:
markSupportedin classAbstractReadableBuffer
-
mark
public void mark()
Description copied from interface:ReadableBufferMarks the current position in this buffer. A subsequent call to theReadableBuffer.reset()method repositions this stream at the last marked position so that subsequent reads re-read the same bytes.- Specified by:
markin interfaceReadableBuffer- Overrides:
markin classAbstractReadableBuffer
-
reset
public void reset()
Description copied from interface:ReadableBufferRepositions this buffer to the position at the timeReadableBuffer.mark()was last called on this buffer.- Specified by:
resetin interfaceReadableBuffer- Overrides:
resetin classAbstractReadableBuffer
-
byteBufferSupported
public boolean byteBufferSupported()
Description copied from interface:ReadableBufferIndicates whether or notReadableBuffer.getByteBuffer()operation is supported for this buffer.- Specified by:
byteBufferSupportedin interfaceReadableBuffer- Overrides:
byteBufferSupportedin classAbstractReadableBuffer
-
getByteBuffer
public java.nio.ByteBuffer getByteBuffer()
Description copied from interface:ReadableBufferGets aByteBufferthat contains some bytes of the content next to be read, ornullif this buffer has been exhausted. The number of bytes contained in the returned buffer is implementation specific. The position of this buffer is unchanged after calling this method. 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 buffer. Buffers returned by this method have independent position, limit and mark. This is an optional method, so callers should first checkReadableBuffer.byteBufferSupported().- Specified by:
getByteBufferin interfaceReadableBuffer- Overrides:
getByteBufferin classAbstractReadableBuffer
-
-