Package io.grpc.internal
Class ReadableBuffers.ByteArrayWrapper
- java.lang.Object
-
- io.grpc.internal.AbstractReadableBuffer
-
- io.grpc.internal.ReadableBuffers.ByteArrayWrapper
-
- All Implemented Interfaces:
ReadableBuffer,java.io.Closeable,java.lang.AutoCloseable
- Enclosing class:
- ReadableBuffers
private static class ReadableBuffers.ByteArrayWrapper extends AbstractReadableBuffer
AReadableBufferthat is backed by a byte array.
-
-
Constructor Summary
Constructors Constructor Description ByteArrayWrapper(byte[] bytes)ByteArrayWrapper(byte[] bytes, int offset, int length)
-
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.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 destIndex, int length)Readslengthbytes from this buffer and writes them to the destination array.ReadableBuffers.ByteArrayWrapperreadBytes(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
byteBufferSupported, checkReadable, close, getByteBuffer, 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.
-
skipBytes
public void skipBytes(int length)
Description copied from interface:ReadableBufferIncrements the read position by the given length.
-
readUnsignedByte
public int readUnsignedByte()
Description copied from interface:ReadableBufferReads the next unsigned byte from this buffer and increments the read position by 1.
-
readBytes
public void readBytes(byte[] dest, int destIndex, 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.destIndex- 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.ByteArrayWrapper 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
-
-