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 TypeClassDescriptionclassAbstract base class forReadableBufferimplementations.classAReadableBufferthat is composed of 0 or moreReadableBuffers.classBase class for a wrapper around anotherReadableBuffer.private static classAReadableBufferthat is backed by a byte array.private static classAReadableBufferthat is backed by aByteBuffer.Fields in io.grpc.internal declared as ReadableBufferModifier and TypeFieldDescriptionprivate final ReadableBufferForwardingReadableBuffer.bufprivate ReadableBufferReadableBuffers.BufferInputStream.bufferprivate static final ReadableBufferReadableBuffers.EMPTY_BUFFERFields in io.grpc.internal with type parameters of type ReadableBufferModifier and TypeFieldDescriptionprivate final Queue<ReadableBuffer> CompositeReadableBuffer.buffersprivate final Deque<ReadableBuffer> CompositeReadableBuffer.readableBuffersprivate Deque<ReadableBuffer> CompositeReadableBuffer.rewindableBuffersMethods in io.grpc.internal that return ReadableBufferModifier and TypeMethodDescriptionstatic ReadableBufferReadableBuffers.empty()Returns an emptyReadableBufferinstance.static ReadableBufferReadableBuffers.ignoreClose(ReadableBuffer buffer) Decorates the givenReadableBufferto ignore calls toReadableBuffer.close().CompositeReadableBuffer.readBytes(int length) ForwardingReadableBuffer.readBytes(int length) ReadableBuffer.readBytes(int length) Readslengthbytes from this buffer and returns a new Buffer containing them.static ReadableBufferReadableBuffers.wrap(byte[] bytes) Shortcut forwrap(bytes, 0, bytes.length.static ReadableBufferReadableBuffers.wrap(byte[] bytes, int offset, int length) Creates a newReadableBufferthat is backed by the given byte array.static ReadableBufferReadableBuffers.wrap(ByteBuffer bytes) Creates a newReadableBufferthat is backed by the givenByteBuffer.Methods in io.grpc.internal with parameters of type ReadableBufferModifier and TypeMethodDescriptionvoidCompositeReadableBuffer.addBuffer(ReadableBuffer buffer) Adds a newReadableBufferat the end of the buffer list.(package private) voidGzipInflatingBuffer.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 voidAbstractStream.TransportState.deframe(ReadableBuffer frame) Called to parse a received frame and attempt delivery of any completed messages.voidApplicationThreadDeframer.deframe(ReadableBuffer data) voidDeframer.deframe(ReadableBuffer data) Adds the given data to this deframer and attempts delivery to the listener.voidMessageDeframer.deframe(ReadableBuffer data) voidMigratingThreadDeframer.deframe(ReadableBuffer data) private voidCompositeReadableBuffer.enqueueBuffer(ReadableBuffer buffer) static ReadableBufferReadableBuffers.ignoreClose(ReadableBuffer buffer) Decorates the givenReadableBufferto ignore calls toReadableBuffer.close().protected voidAbstractClientStream.TransportState.inboundDataReceived(ReadableBuffer frame) Processes the contents of a received data frame from the server.voidAbstractServerStream.TransportState.inboundDataReceived(ReadableBuffer frame, boolean endOfStream) Called in the transport thread to process the content of an inbound DATA frame from the client.static InputStreamReadableBuffers.openStream(ReadableBuffer buffer, boolean owner) Creates a newInputStreambacked by the given buffer.intCompositeReadableBuffer.NoThrowReadOperation.read(ReadableBuffer buffer, int length, T dest, int value) intCompositeReadableBuffer.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 entireReadableBufferto a new array.static StringReadableBuffers.readAsString(ReadableBuffer buffer, Charset charset) Reads the entireReadableBufferto a newStringwith the given charset.static StringReadableBuffers.readAsStringUtf8(ReadableBuffer buffer) Reads the entireReadableBufferto a newStringusing UTF-8 decoding.protected voidHttp2ClientStreamTransportState.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) classABufferimplementation that is backed by a NettyByteBuf.