Home
last modified time | relevance | path

Searched defs:endOfStream (Results 1 – 15 of 15) sorted by relevance

/external/grpc-grpc-java/cronet/src/main/java/io/grpc/cronet/
DCronetClientStream.java165 WritableBuffer buffer, boolean endOfStream, boolean flush, int numMessages) { in writeFrame()
280 private void transportHeadersReceived(Metadata metadata, boolean endOfStream) { in transportHeadersReceived()
289 private void transportDataReceived(ByteBuffer buffer, boolean endOfStream) { in transportDataReceived()
291 super.transportDataReceived(ReadableBuffers.wrap(buffer), endOfStream); in transportDataReceived() local
347 private void streamWrite(ByteBuffer buffer, boolean endOfStream, boolean flush) { in streamWrite()
398 ByteBuffer buffer, boolean endOfStream) { in onReadCompleted()
420 ByteBuffer buffer, boolean endOfStream) { in onWriteCompleted()
505 private void reportHeaders(List<Map.Entry<String, String>> headers, boolean endOfStream) { in reportHeaders()
539 boolean endOfStream; field in CronetClientStream.PendingData
542 PendingData(ByteBuffer buffer, boolean endOfStream, boolean flush) { in PendingData()
/external/grpc-grpc-java/okhttp/src/main/java/io/grpc/okhttp/
DOkHttpClientStream.java150 WritableBuffer frame, boolean endOfStream, boolean flush, int numMessages) { in writeFrame()
297 public void transportHeadersReceived(List<Header> headers, boolean endOfStream) { in transportHeadersReceived()
309 public void transportDataReceived(okio.Buffer frame, boolean endOfStream) { in transportDataReceived()
362 private void sendBuffer(Buffer buffer, boolean endOfStream, boolean flush) { in sendBuffer()
394 boolean endOfStream; field in OkHttpClientStream.PendingData
397 PendingData(Buffer buffer, boolean endOfStream, boolean flush) { in PendingData()
/external/grpc-grpc-java/core/src/main/java/io/grpc/internal/
DAbstractServerStream.java119 WritableBuffer frame, boolean endOfStream, boolean flush, int numMessages) { in deliverFrame()
194 private boolean endOfStream = false; field in AbstractServerStream.TransportState
263 public void inboundDataReceived(ReadableBuffer frame, boolean endOfStream) { in inboundDataReceived()
DHttp2ClientStreamTransportState.java129 protected void transportDataReceived(ReadableBuffer frame, boolean endOfStream) { in transportDataReceived()
DMessageFramer.java62 boolean endOfStream, in deliverFrame()
347 private void commitToSink(boolean endOfStream, boolean flush) { in commitToSink()
DAbstractClientStream.java77 @Nullable WritableBuffer frame, boolean endOfStream, boolean flush, int numMessages); in writeFrame()
182 WritableBuffer frame, boolean endOfStream, boolean flush, int numMessages) { in deliverFrame()
/external/grpc-grpc-java/netty/src/main/java/io/grpc/netty/
DNettyClientStream.java161 WritableBuffer frame, boolean endOfStream, boolean flush, final int numMessages) { in writeFrame()
293 void transportHeadersReceived(Http2Headers headers, boolean endOfStream) { in transportHeadersReceived()
304 void transportDataReceived(ByteBuf frame, boolean endOfStream) { in transportDataReceived()
DSendResponseHeadersCommand.java56 boolean endOfStream() { in endOfStream() method in SendResponseHeadersCommand
DNettyServerStream.java197 void inboundDataReceived(ByteBuf frame, boolean endOfStream) { in inboundDataReceived()
DNettyClientHandler.java352 private void onDataRead(int streamId, ByteBuf data, int padding, boolean endOfStream) { in onDataRead()
751 boolean endOfStream) throws Http2Exception { in onDataRead()
DNettyServerHandler.java459 private void onDataRead(int streamId, ByteBuf data, int padding, boolean endOfStream) in onDataRead()
720 boolean endOfStream) throws Http2Exception { in onDataRead()
/external/brotli/csharp/org/brotli/dec/
DBitReader.cs97 internal static void CheckHealth(Org.Brotli.Dec.BitReader br, bool endOfStream) in CheckHealth()
/external/brotli/java/org/brotli/dec/
DBitReader.java79 static void checkHealth(State s, int endOfStream) { in checkHealth()
/external/grpc-grpc-java/core/src/test/java/io/grpc/internal/
DAbstractClientStreamTest.java521 WritableBuffer frame, boolean endOfStream, boolean flush, int numMessages) {} in writeFrame()
/external/brotli/js/
Ddecode.js1273 function checkHealth(s, endOfStream) { argument