Home
last modified time | relevance | path

Searched refs:deframerClosed (Results 1 – 7 of 7) sorted by relevance

/external/grpc-grpc-java/core/src/main/java/io/grpc/internal/
DAbstractServerStream.java195 private boolean deframerClosed = false; field in AbstractServerStream.TransportState
229 public void deframerClosed(boolean hasPartialMessage) { in deframerClosed() method in AbstractServerStream.TransportState
230 deframerClosed = true; in deframerClosed()
285 if (deframerClosed) { in transportReportStatus()
307 if (deframerClosed) { in complete()
DAbstractClientStream.java220 private boolean deframerClosed = false; field in AbstractClientStream.TransportState
259 public void deframerClosed(boolean hasPartialMessage) { in deframerClosed() method in AbstractClientStream.TransportState
260 deframerClosed = true; in deframerClosed()
427 if (deframerClosed) { in transportReportStatus()
DApplicationThreadDeframer.java153 public void deframerClosed(final boolean hasPartialMessage) { in deframerClosed() method in ApplicationThreadDeframer
158 storedListener.deframerClosed(hasPartialMessage); in deframerClosed()
DMessageDeframer.java74 void deframerClosed(boolean hasPartialMessage); in deframerClosed() method
229 listener.deframerClosed(hasPartialMessage); in close()
/external/grpc-grpc-java/core/src/test/java/io/grpc/internal/
DMessageDeframerTest.java155 verify(listener).deframerClosed(false); in endOfStreamWithPayloadShouldNotifyEndOfStream()
170 verify(listener).deframerClosed(false); in endOfStreamShouldNotifyEndOfStream()
181 verify(listener).deframerClosed(true); in endOfStreamWithPartialMessageShouldNotifyDeframerClosedWithPartialMessage()
197 verify(listener).deframerClosed(true); in endOfStreamWithInvalidGzipBlockShouldNotifyDeframerClosedWithPartialMessage()
277 verify(listener).deframerClosed(false); in endOfStreamCallbackShouldWaitForMessageDelivery()
318 verify(listener).deframerClosed(false);
DApplicationThreadDeframerTest.java101 applicationThreadDeframer.deframerClosed(true); in deframerClosedInvokesTransportExecutor()
159 public void deframerClosed(boolean hasPartialMessage) { in deframerClosed() method in ApplicationThreadDeframerTest.DeframerListener
/external/grpc-grpc-java/okhttp/src/main/java/io/grpc/okhttp/
DOkHttpClientStream.java280 public void deframerClosed(boolean hasPartialMessage) { in deframerClosed() method in OkHttpClientStream.TransportState
282 super.deframerClosed(hasPartialMessage); in deframerClosed()