Home
last modified time | relevance | path

Searched refs:hasPartialMessage (Results 1 – 6 of 6) sorted by relevance

/external/grpc-grpc-java/core/src/main/java/io/grpc/internal/
DMessageDeframer.java74 void deframerClosed(boolean hasPartialMessage); in deframerClosed() argument
212 boolean hasPartialMessage = nextFrame != null && nextFrame.readableBytes() > 0; in close()
215 hasPartialMessage = hasPartialMessage || fullStreamDecompressor.hasPartialData(); in close()
229 listener.deframerClosed(hasPartialMessage); in close()
DApplicationThreadDeframer.java153 public void deframerClosed(final boolean hasPartialMessage) { in deframerClosed() argument
158 storedListener.deframerClosed(hasPartialMessage); in deframerClosed()
DAbstractServerStream.java229 public void deframerClosed(boolean hasPartialMessage) { in deframerClosed() argument
232 if (!immediateCloseRequested && hasPartialMessage) { in deframerClosed()
DAbstractClientStream.java259 public void deframerClosed(boolean hasPartialMessage) { in deframerClosed() argument
263 if (trailerStatus.isOk() && hasPartialMessage) { in deframerClosed()
/external/grpc-grpc-java/core/src/test/java/io/grpc/internal/
DApplicationThreadDeframerTest.java159 public void deframerClosed(boolean hasPartialMessage) { in deframerClosed() argument
161 deframerClosedWithPartialMessage = hasPartialMessage; in deframerClosed()
/external/grpc-grpc-java/okhttp/src/main/java/io/grpc/okhttp/
DOkHttpClientStream.java280 public void deframerClosed(boolean hasPartialMessage) { in deframerClosed() argument
282 super.deframerClosed(hasPartialMessage); in deframerClosed()