HomeSort by relevance Sort by last modified time
    Searched defs:endOfStream (Results 1 - 10 of 10) sorted by null

  /external/grpc-grpc-java/netty/src/main/java/io/grpc/netty/
SendResponseHeadersCommand.java 56 boolean endOfStream() {
  /external/grpc-grpc-java/core/src/main/java/io/grpc/internal/
AbstractServerStream.java 119 WritableBuffer frame, boolean endOfStream, boolean flush, int numMessages) {
120 // Since endOfStream is triggered by the sending of trailers, avoid flush here and just flush
122 abstractServerStreamSink().writeFrame(frame, endOfStream ? false : flush, numMessages);
194 private boolean endOfStream = false;
231 if (endOfStream) {
261 * @param endOfStream {@code true} if no more data will be received on the stream.
263 public void inboundDataReceived(ReadableBuffer frame, boolean endOfStream) {
264 Preconditions.checkState(!this.endOfStream, "Past end of stream");
267 if (endOfStream) {
268 this.endOfStream = true
    [all...]
  /external/grpc-grpc-java/okhttp/src/main/java/io/grpc/okhttp/
OkHttpClientStream.java 150 WritableBuffer frame, boolean endOfStream, boolean flush, int numMessages) {
163 state.sendBuffer(buffer, endOfStream, flush);
235 outboundFlow.data(data.endOfStream, id, data.buffer, false);
297 public void transportHeadersReceived(List<Header> headers, boolean endOfStream) {
298 if (endOfStream) {
309 public void transportDataReceived(okio.Buffer frame, boolean endOfStream) {
323 super.transportDataReceived(new OkHttpReadableBuffer(frame), endOfStream);
362 private void sendBuffer(Buffer buffer, boolean endOfStream, boolean flush) {
368 pendingData.add(new PendingData(buffer, endOfStream, flush));
373 outboundFlow.data(endOfStream, id(), buffer, flush)
    [all...]
  /external/grpc-grpc-java/cronet/src/main/java/io/grpc/cronet/
CronetClientStream.java 165 WritableBuffer buffer, boolean endOfStream, boolean flush, int numMessages) {
179 state.enqueuePendingData(new PendingData(byteBuffer, endOfStream, flush));
181 streamWrite(byteBuffer, endOfStream, flush);
280 private void transportHeadersReceived(Metadata metadata, boolean endOfStream) {
281 if (endOfStream) {
289 private void transportDataReceived(ByteBuffer buffer, boolean endOfStream) {
291 super.transportDataReceived(ReadableBuffers.wrap(buffer), endOfStream);
310 streamWrite(data.buffer, data.endOfStream, data.flush);
347 private void streamWrite(ByteBuffer buffer, boolean endOfStream, boolean flush) {
351 stream.write(buffer, endOfStream);
    [all...]
  /external/grpc-grpc-java/netty/shaded/
grpc-netty-shaded-1.14.0.jar 
  /external/guice/extensions/persist/lib/
oro-2.0.8.jar 
  /external/grpc-grpc-java/core/
grpc-core-1.14.0.jar 
  /external/guice/extensions/struts2/lib/
ant-1.6.5.jar 
  /external/jarjar/lib/
apache-ant-1.9.4.jar 
  /external/owasp/sanitizer/tools/findbugs/lib/
ant.jar 

Completed in 1954 milliseconds