Package | Description |
---|---|
io.grpc.internal |
Interfaces and implementations that are internal to gRPC.
|
Modifier and Type | Class and Description |
---|---|
class |
AbstractReadableBuffer
Abstract base class for
ReadableBuffer implementations. |
class |
CompositeReadableBuffer
A
ReadableBuffer that is composed of 0 or more ReadableBuffer s. |
class |
ForwardingReadableBuffer
Base class for a wrapper around another
ReadableBuffer . |
Modifier and Type | Method and Description |
---|---|
static ReadableBuffer |
ReadableBuffers.empty()
Returns an empty
ReadableBuffer instance. |
static ReadableBuffer |
ReadableBuffers.ignoreClose(ReadableBuffer buffer)
Decorates the given
ReadableBuffer to ignore calls to close() . |
ReadableBuffer |
ReadableBuffer.readBytes(int length)
Reads
length bytes from this buffer and returns a new Buffer containing them. |
ReadableBuffer |
ForwardingReadableBuffer.readBytes(int length) |
static ReadableBuffer |
ReadableBuffers.wrap(byte[] bytes)
Shortcut for
wrap(bytes, 0, bytes.length . |
static ReadableBuffer |
ReadableBuffers.wrap(byte[] bytes,
int offset,
int length)
Creates a new
ReadableBuffer that is backed by the given byte array. |
static ReadableBuffer |
ReadableBuffers.wrap(ByteBuffer bytes)
Creates a new
ReadableBuffer that is backed by the given ByteBuffer . |
Modifier and Type | Method and Description |
---|---|
void |
CompositeReadableBuffer.addBuffer(ReadableBuffer buffer)
Adds a new
ReadableBuffer at the end of the buffer list. |
void |
MessageDeframer.deframe(ReadableBuffer data) |
void |
Deframer.deframe(ReadableBuffer data)
Adds the given data to this deframer and attempts delivery to the listener.
|
void |
ApplicationThreadDeframer.deframe(ReadableBuffer data) |
protected void |
AbstractStream.TransportState.deframe(ReadableBuffer frame)
Called to parse a received frame and attempt delivery of any completed messages.
|
static ReadableBuffer |
ReadableBuffers.ignoreClose(ReadableBuffer buffer)
Decorates the given
ReadableBuffer to ignore calls to close() . |
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 new
InputStream backed by the given buffer. |
static byte[] |
ReadableBuffers.readArray(ReadableBuffer buffer)
Reads an entire
ReadableBuffer to a new array. |
static String |
ReadableBuffers.readAsString(ReadableBuffer buffer,
Charset charset)
Reads the entire
ReadableBuffer to a new String with the given charset. |
static String |
ReadableBuffers.readAsStringUtf8(ReadableBuffer buffer)
Reads the entire
ReadableBuffer to a new String using UTF-8 decoding. |
protected void |
Http2ClientStreamTransportState.transportDataReceived(ReadableBuffer frame,
boolean endOfStream)
Called by subclasses whenever a data frame is received from the transport.
|
Constructor and Description |
---|
ForwardingReadableBuffer(ReadableBuffer buf)
Constructor.
|
Copyright © 2019. All rights reserved.