Uses of Interface
io.grpc.internal.ReadableBuffer
Packages that use ReadableBuffer
Package
Description
Interfaces and implementations that are internal to gRPC.
The main transport implementation based on Netty,
for both the client and the server.
-
Uses of ReadableBuffer in io.grpc.internal
Classes in io.grpc.internal that implement ReadableBufferModifier and TypeClassDescriptionclass
Abstract base class forReadableBuffer
implementations.class
AReadableBuffer
that is composed of 0 or moreReadableBuffer
s.class
Base class for a wrapper around anotherReadableBuffer
.private static class
AReadableBuffer
that is backed by a byte array.private static class
AReadableBuffer
that is backed by aByteBuffer
.Fields in io.grpc.internal declared as ReadableBufferModifier and TypeFieldDescriptionprivate final ReadableBuffer
ForwardingReadableBuffer.buf
private ReadableBuffer
ReadableBuffers.BufferInputStream.buffer
private static final ReadableBuffer
ReadableBuffers.EMPTY_BUFFER
Fields in io.grpc.internal with type parameters of type ReadableBufferModifier and TypeFieldDescriptionprivate final Queue
<ReadableBuffer> CompositeReadableBuffer.buffers
private final Deque
<ReadableBuffer> CompositeReadableBuffer.readableBuffers
private Deque
<ReadableBuffer> CompositeReadableBuffer.rewindableBuffers
Methods in io.grpc.internal that return ReadableBufferModifier and TypeMethodDescriptionstatic ReadableBuffer
ReadableBuffers.empty()
Returns an emptyReadableBuffer
instance.static ReadableBuffer
ReadableBuffers.ignoreClose
(ReadableBuffer buffer) Decorates the givenReadableBuffer
to ignore calls toclose()
.CompositeReadableBuffer.readBytes
(int length) ForwardingReadableBuffer.readBytes
(int length) ReadableBuffer.readBytes
(int length) Readslength
bytes from this buffer and returns a new Buffer containing them.static ReadableBuffer
ReadableBuffers.wrap
(byte[] bytes) Shortcut forwrap(bytes, 0, bytes.length
.static ReadableBuffer
ReadableBuffers.wrap
(byte[] bytes, int offset, int length) Creates a newReadableBuffer
that is backed by the given byte array.static ReadableBuffer
ReadableBuffers.wrap
(ByteBuffer bytes) Creates a newReadableBuffer
that is backed by the givenByteBuffer
.Methods in io.grpc.internal with parameters of type ReadableBufferModifier and TypeMethodDescriptionvoid
CompositeReadableBuffer.addBuffer
(ReadableBuffer buffer) Adds a newReadableBuffer
at the end of the buffer list.(package private) void
GzipInflatingBuffer.addGzippedBytes
(ReadableBuffer buffer) Adds more gzipped data, which will be consumed only when needed to fulfill requests made viaGzipInflatingBuffer.inflateBytes(byte[], int, int)
.protected final void
AbstractStream.TransportState.deframe
(ReadableBuffer frame) Called to parse a received frame and attempt delivery of any completed messages.void
ApplicationThreadDeframer.deframe
(ReadableBuffer data) void
Deframer.deframe
(ReadableBuffer data) Adds the given data to this deframer and attempts delivery to the listener.void
MessageDeframer.deframe
(ReadableBuffer data) void
MigratingThreadDeframer.deframe
(ReadableBuffer data) private void
CompositeReadableBuffer.enqueueBuffer
(ReadableBuffer buffer) static ReadableBuffer
ReadableBuffers.ignoreClose
(ReadableBuffer buffer) Decorates the givenReadableBuffer
to ignore calls toclose()
.protected void
AbstractClientStream.TransportState.inboundDataReceived
(ReadableBuffer frame) Processes the contents of a received data frame from the server.void
AbstractServerStream.TransportState.inboundDataReceived
(ReadableBuffer frame, boolean endOfStream) Called in the transport thread to process the content of an inbound DATA frame from the client.static InputStream
ReadableBuffers.openStream
(ReadableBuffer buffer, boolean owner) Creates a newInputStream
backed by the given buffer.int
CompositeReadableBuffer.NoThrowReadOperation.read
(ReadableBuffer buffer, int length, T dest, int value) int
CompositeReadableBuffer.ReadOperation.read
(ReadableBuffer buffer, int length, T dest, int value) This method can also be used to simultaneously perform operation-specific int-valued aggregation over the sequence of buffers in aCompositeReadableBuffer
.static byte[]
ReadableBuffers.readArray
(ReadableBuffer buffer) Reads an entireReadableBuffer
to a new array.static String
ReadableBuffers.readAsString
(ReadableBuffer buffer, Charset charset) Reads the entireReadableBuffer
to a newString
with the given charset.static String
ReadableBuffers.readAsStringUtf8
(ReadableBuffer buffer) Reads the entireReadableBuffer
to a newString
using UTF-8 decoding.protected void
Http2ClientStreamTransportState.transportDataReceived
(ReadableBuffer frame, boolean endOfStream) Called by subclasses whenever a data frame is received from the transport.Constructors in io.grpc.internal with parameters of type ReadableBuffer -
Uses of ReadableBuffer in io.grpc.netty
Classes in io.grpc.netty that implement ReadableBufferModifier and TypeClassDescription(package private) class
ABuffer
implementation that is backed by a NettyByteBuf
.