Uses of Interface
io.grpc.internal.ReadableBuffer
-
Packages that use ReadableBuffer Package Description io.grpc.internal Interfaces and implementations that are internal to gRPC.io.grpc.netty 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 ReadableBuffer Modifier and Type Class Description class
AbstractReadableBuffer
Abstract base class forReadableBuffer
implementations.class
CompositeReadableBuffer
AReadableBuffer
that is composed of 0 or moreReadableBuffer
s.class
ForwardingReadableBuffer
Base class for a wrapper around anotherReadableBuffer
.private static class
ReadableBuffers.ByteArrayWrapper
AReadableBuffer
that is backed by a byte array.private static class
ReadableBuffers.ByteReadableBufferWrapper
AReadableBuffer
that is backed by aByteBuffer
.Fields in io.grpc.internal declared as ReadableBuffer Modifier and Type Field Description private ReadableBuffer
ForwardingReadableBuffer. buf
private ReadableBuffer
ReadableBuffers.BufferInputStream. buffer
private static ReadableBuffer
ReadableBuffers. EMPTY_BUFFER
Fields in io.grpc.internal with type parameters of type ReadableBuffer Modifier and Type Field Description private java.util.Queue<ReadableBuffer>
CompositeReadableBuffer. buffers
private java.util.Deque<ReadableBuffer>
CompositeReadableBuffer. readableBuffers
private java.util.Deque<ReadableBuffer>
CompositeReadableBuffer. rewindableBuffers
Methods in io.grpc.internal that return ReadableBuffer Modifier and Type Method Description static ReadableBuffer
ReadableBuffers. empty()
Returns an emptyReadableBuffer
instance.static ReadableBuffer
ReadableBuffers. ignoreClose(ReadableBuffer buffer)
Decorates the givenReadableBuffer
to ignore calls toclose()
.ReadableBuffer
CompositeReadableBuffer. readBytes(int length)
ReadableBuffer
ForwardingReadableBuffer. readBytes(int length)
ReadableBuffer
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(java.nio.ByteBuffer bytes)
Creates a newReadableBuffer
that is backed by the givenByteBuffer
.Methods in io.grpc.internal with parameters of type ReadableBuffer Modifier and Type Method Description void
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 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 java.io.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 java.lang.String
ReadableBuffers. readAsString(ReadableBuffer buffer, java.nio.charset.Charset charset)
Reads the entireReadableBuffer
to a newString
with the given charset.static java.lang.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 Constructor Description BufferInputStream(ReadableBuffer buffer)
ForwardingReadableBuffer(ReadableBuffer buf)
Constructor. -
Uses of ReadableBuffer in io.grpc.netty
Classes in io.grpc.netty that implement ReadableBuffer Modifier and Type Class Description (package private) class
NettyReadableBuffer
ABuffer
implementation that is backed by a NettyByteBuf
.
-