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 classAbstractReadableBufferAbstract base class forReadableBufferimplementations.classCompositeReadableBufferAReadableBufferthat is composed of 0 or moreReadableBuffers.classForwardingReadableBufferBase class for a wrapper around anotherReadableBuffer.private static classReadableBuffers.ByteArrayWrapperAReadableBufferthat is backed by a byte array.private static classReadableBuffers.ByteReadableBufferWrapperAReadableBufferthat is backed by aByteBuffer.Fields in io.grpc.internal declared as ReadableBuffer Modifier and Type Field Description private ReadableBufferForwardingReadableBuffer. bufprivate ReadableBufferReadableBuffers.BufferInputStream. bufferprivate static ReadableBufferReadableBuffers. EMPTY_BUFFERFields in io.grpc.internal with type parameters of type ReadableBuffer Modifier and Type Field Description private java.util.Queue<ReadableBuffer>CompositeReadableBuffer. buffersprivate java.util.Deque<ReadableBuffer>CompositeReadableBuffer. readableBuffersprivate java.util.Deque<ReadableBuffer>CompositeReadableBuffer. rewindableBuffersMethods in io.grpc.internal that return ReadableBuffer Modifier and Type Method Description static ReadableBufferReadableBuffers. empty()Returns an emptyReadableBufferinstance.static ReadableBufferReadableBuffers. ignoreClose(ReadableBuffer buffer)Decorates the givenReadableBufferto ignore calls toclose().ReadableBufferCompositeReadableBuffer. readBytes(int length)ReadableBufferForwardingReadableBuffer. readBytes(int length)ReadableBufferReadableBuffer. 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(java.nio.ByteBuffer bytes)Creates a newReadableBufferthat is backed by the givenByteBuffer.Methods in io.grpc.internal with parameters of type ReadableBuffer Modifier and Type Method Description voidCompositeReadableBuffer. 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 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 toclose().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 java.io.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 java.lang.StringReadableBuffers. readAsString(ReadableBuffer buffer, java.nio.charset.Charset charset)Reads the entireReadableBufferto a newStringwith the given charset.static java.lang.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 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) classNettyReadableBufferABufferimplementation that is backed by a NettyByteBuf.
-