Home
last modified time | relevance | path

Searched refs:ReadableBuffer (Results 1 – 25 of 25) sorted by relevance

/external/grpc-grpc-java/core/src/main/java/io/grpc/internal/
DCompositeReadableBuffer.java36 private final Queue<ReadableBuffer> buffers = new ArrayDeque<ReadableBuffer>();
44 public void addBuffer(ReadableBuffer buffer) { in addBuffer()
53 ReadableBuffer subBuffer = compositeBuffer.buffers.remove(); in addBuffer()
70 int readInternal(ReadableBuffer buffer, int length) { in readUnsignedByte()
82 public int readInternal(ReadableBuffer buffer, int length) { in skipBytes()
94 public int readInternal(ReadableBuffer buffer, int length) { in readBytes()
106 public int readInternal(ReadableBuffer buffer, int length) { in readBytes()
123 public int readInternal(ReadableBuffer buffer, int length) throws IOException { in readBytes()
143 ReadableBuffer buffer = buffers.peek(); in readBytes()
174 ReadableBuffer buffer = buffers.peek(); in execute()
[all …]
DReadableBuffers.java33 private static final ReadableBuffer EMPTY_BUFFER = new ByteArrayWrapper(new byte[0]);
38 public static ReadableBuffer empty() { in empty()
45 public static ReadableBuffer wrap(byte[] bytes) { in wrap()
56 public static ReadableBuffer wrap(byte[] bytes, int offset, int length) { in wrap()
64 public static ReadableBuffer wrap(ByteBuffer bytes) { in wrap()
72 public static byte[] readArray(ReadableBuffer buffer) { in readArray()
83 public static String readAsString(ReadableBuffer buffer, Charset charset) { in readAsString()
92 public static String readAsStringUtf8(ReadableBuffer buffer) { in readAsStringUtf8()
104 public static InputStream openStream(ReadableBuffer buffer, boolean owner) { in openStream()
114 public static ReadableBuffer ignoreClose(ReadableBuffer buffer) { in ignoreClose()
[all …]
DForwardingReadableBuffer.java31 public abstract class ForwardingReadableBuffer implements ReadableBuffer {
33 private final ReadableBuffer buf;
40 public ForwardingReadableBuffer(ReadableBuffer buf) { in ForwardingReadableBuffer()
80 public ReadableBuffer readBytes(int length) { in readBytes()
DReadableBuffer.java32 public interface ReadableBuffer extends Closeable { interface
103 ReadableBuffer readBytes(int length); in readBytes()
DDeframer.java58 void deframe(ReadableBuffer data); in deframe()
DAbstractReadableBuffer.java22 public abstract class AbstractReadableBuffer implements ReadableBuffer {
DApplicationThreadDeframer.java92 public void deframe(final ReadableBuffer data) { in deframe()
DAbstractStream.java191 protected final void deframe(final ReadableBuffer frame) { in deframe()
DHttp2ClientStreamTransportState.java129 protected void transportDataReceived(ReadableBuffer frame, boolean endOfStream) { in transportDataReceived()
DAbstractServerStream.java263 public void inboundDataReceived(ReadableBuffer frame, boolean endOfStream) { in inboundDataReceived()
DGzipInflatingBuffer.java209 void addGzippedBytes(ReadableBuffer buffer) { in addGzippedBytes()
DMessageDeframer.java165 public void deframe(ReadableBuffer data) { in deframe()
DAbstractClientStream.java346 protected void inboundDataReceived(ReadableBuffer frame) { in inboundDataReceived()
/external/grpc-grpc-java/core/src/test/java/io/grpc/internal/
DReadableBuffersTest.java42 ReadableBuffer buffer = ReadableBuffers.empty(); in empty_returnsEmptyBuffer()
53 ReadableBuffer buffer = ReadableBuffers.wrap(MSG_BYTES); in readArray_returnsBufferArray()
59 ReadableBuffer buffer = ReadableBuffers.wrap(MSG_BYTES); in readAsString_returnsString()
70 ReadableBuffer buffer = ReadableBuffers.wrap(MSG_BYTES); in readAsStringUtf8_returnsString()
81 ReadableBuffer buffer = mock(ReadableBuffer.class); in openStream_ignoresClose()
89 ReadableBuffer buffer = ReadableBuffers.wrap(MSG_BYTES); in bufferInputStream_available_returnsReadableBytes()
100 ReadableBuffer buffer = ReadableBuffers.wrap(MSG_BYTES); in bufferInputStream_read_returnsUnsignedByte()
107 ReadableBuffer buffer = ReadableBuffers.wrap(MSG_BYTES); in bufferInputStream_read_writes()
117 ReadableBuffer buffer = ReadableBuffers.wrap(MSG_BYTES); in bufferInputStream_read_writesPartially()
126 ReadableBuffer buffer = mock(ReadableBuffer.class); in bufferInputStream_close_closesBuffer()
DReadableBufferTestBase.java40 ReadableBuffer buffer = buffer(); in bufferShouldReadAllBytes()
50 ReadableBuffer buffer = buffer(); in readToArrayShouldSucceed()
59 ReadableBuffer buffer = buffer(); in partialReadToArrayShouldSucceed()
68 ReadableBuffer buffer = buffer(); in readToStreamShouldSucceed()
77 ReadableBuffer buffer = buffer(); in partialReadToStreamShouldSucceed()
86 ReadableBuffer buffer = buffer(); in readToByteBufferShouldSucceed()
98 ReadableBuffer buffer = buffer(); in partialReadToByteBufferShouldSucceed()
110 ReadableBuffer buffer = buffer(); in partialReadToReadableBufferShouldSucceed()
111 ReadableBuffer newBuffer = buffer.readBytes(2); in partialReadToReadableBufferShouldSucceed()
119 protected abstract ReadableBuffer buffer(); in buffer()
DCompositeReadableBufferTest.java159 ReadableBuffer mock1 = mock(ReadableBuffer.class); in closeShouldCloseBuffers()
160 ReadableBuffer mock2 = mock(ReadableBuffer.class); in closeShouldCloseBuffers()
DReadableBuffersArrayTest.java36 ReadableBuffer buffer = wrap(array, 1, msg.length() - 1); in bufferShouldExposeArray()
47 protected ReadableBuffer buffer() { in buffer()
DForwardingReadableBufferTest.java43 @Mock private ReadableBuffer delegate;
55 ReadableBuffer.class, in allMethodsForwarded()
DReadableBuffersByteBufferTest.java30 protected ReadableBuffer buffer() { in buffer()
DAbstractServerStreamTest.java96 ReadableBuffer buffer = mock(ReadableBuffer.class); in frameShouldBeIgnoredAfterDeframerClosed()
DApplicationThreadDeframerTest.java67 ReadableBuffer frame = ReadableBuffers.wrap(new byte[1]); in deframeInvokesMessagesAvailableOnListener()
DMessageDeframerTest.java107 public void addGzippedBytes(ReadableBuffer buffer) { in setUp()
531 private static ReadableBuffer buffer(byte[] bytes) {
/external/grpc-grpc-java/okhttp/src/test/java/io/grpc/okhttp/
DOkHttpReadableBufferTest.java19 import io.grpc.internal.ReadableBuffer;
60 protected ReadableBuffer buffer() { in buffer()
/external/grpc-grpc-java/netty/src/test/java/io/grpc/netty/
DNettyReadableBufferTest.java22 import io.grpc.internal.ReadableBuffer;
56 protected ReadableBuffer buffer() { in buffer()
/external/grpc-grpc-java/okhttp/src/main/java/io/grpc/okhttp/
DOkHttpReadableBuffer.java20 import io.grpc.internal.ReadableBuffer;
79 public ReadableBuffer readBytes(int length) { in readBytes()