Home
last modified time | relevance | path

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

/external/grpc-grpc-java/core/src/main/java/io/grpc/internal/
DMessageDeframer.java106 private boolean closeWhenComplete = false; field in MessageDeframer
187 public void closeWhenComplete() { in closeWhenComplete() method in MessageDeframer
193 closeWhenComplete = true; in closeWhenComplete()
241 return isClosed() || closeWhenComplete; in isClosedOrScheduledToClose()
295 if (closeWhenComplete && isStalled()) { in deliver()
DApplicationThreadDeframer.java109 public void closeWhenComplete() { in closeWhenComplete() method in ApplicationThreadDeframer
115 deframer.closeWhenComplete(); in closeWhenComplete()
DDeframer.java61 void closeWhenComplete(); in closeWhenComplete() method
DAbstractStream.java183 deframer.closeWhenComplete(); in closeDeframer()
/external/grpc-grpc-java/core/src/test/java/io/grpc/internal/
DMessageDeframerTest.java152 deframer.closeWhenComplete(); in endOfStreamWithPayloadShouldNotifyEndOfStream()
164 deframer.closeWhenComplete(); in endOfStreamShouldNotifyEndOfStream()
179 deframer.closeWhenComplete(); in endOfStreamWithPartialMessageShouldNotifyDeframerClosedWithPartialMessage()
196 deframer.closeWhenComplete(); in endOfStreamWithInvalidGzipBlockShouldNotifyDeframerClosedWithPartialMessage()
271 deframer.closeWhenComplete(); in endOfStreamCallbackShouldWaitForMessageDelivery()
312 deframer.closeWhenComplete();
DApplicationThreadDeframerTest.java76 applicationThreadDeframer.closeWhenComplete(); in closeWhenCompleteInvokesMessagesAvailableOnListener()
79 verify(mockDeframer).closeWhenComplete(); in closeWhenCompleteInvokesMessagesAvailableOnListener()