| /external/grpc-grpc-java/stub/src/main/java/io/grpc/stub/ |
| D | ServerCalls.java | 234 private boolean halfClosed = false; field in ServerCalls.StreamingServerCallHandler.StreamingServerCallListener
258 halfClosed = true; in onHalfClose()
268 if (!halfClosed) { in onCancel()
|
| /external/grpc-grpc-java/core/src/main/java/io/grpc/internal/ |
| D | ServerStreamListener.java | 29 void halfClosed(); in halfClosed() method
|
| D | ServerImpl.java | 619 public void halfClosed() {} in halfClosed() method in ServerImpl.NoopListener
701 public void halfClosed() { in halfClosed() method in ServerImpl.JumpToApplicationThreadServerStreamListener
710 getListener().halfClosed(); in halfClosed()
|
| D | AbstractServerStream.java | 242 listener.halfClosed(); in deframerClosed()
|
| D | ServerCallImpl.java | 278 public void halfClosed() { in halfClosed() method in ServerCallImpl.ServerStreamListenerImpl
|
| /external/grpc-grpc-java/core/src/test/java/io/grpc/internal/ |
| D | ServerCallImplTest.java | 349 streamListener.halfClosed(); in streamListener_halfClosed()
358 streamListener.halfClosed(); in streamListener_halfClosed_onlyOnce()
362 streamListener.halfClosed(); in streamListener_halfClosed_onlyOnce()
|
| D | ServerImplTest.java | 536 streamListener.halfClosed(); // All full; no dessert. in basicExchangeHelper()
926 streamListener.halfClosed(); in testCallContextIsBoundInListenerCallbacks()
1160 doThrow(expectedT).when(mockListener).halfClosed(); in halfClosed_errorCancelsCall()
1161 listener.halfClosed(); in halfClosed_errorCancelsCall()
1183 doThrow(expectedT).when(mockListener).halfClosed(); in halfClosed_runtimeExceptionCancelsCall()
1184 listener.halfClosed(); in halfClosed_runtimeExceptionCancelsCall()
|
| D | AbstractServerStreamTest.java | 350 public void halfClosed() {} in halfClosed() method in AbstractServerStreamTest.ServerStreamListenerBase
|
| /external/grpc-grpc-java/auth/src/test/java/io/grpc/auth/ |
| D | ClientAuthInterceptorTest.java | 190 private boolean halfClosed; field in ClientAuthInterceptorTest.ClientCallRecorder
212 halfClosed = true; in halfClose()
|
| /external/grpc-grpc-java/stub/src/test/java/io/grpc/stub/ |
| D | ClientCallsTest.java | 138 final AtomicReference<Boolean> halfClosed = new AtomicReference<Boolean>(); in unaryFutureCallSuccess() local
152 halfClosed.set(true); in unaryFutureCallSuccess()
159 assertTrue(halfClosed.get()); in unaryFutureCallSuccess()
|
| /external/grpc-grpc-java/core/src/test/java/io/grpc/ |
| D | ClientInterceptorsTest.java | 329 assertTrue(call.halfClosed); in normalCall()
428 private boolean halfClosed; field in ClientInterceptorsTest.BaseClientCall
458 this.halfClosed = true; in halfClose()
|
| /external/grpc-grpc-java/netty/src/test/java/io/grpc/netty/ |
| D | NettyServerStreamTest.java | 211 verify(serverListener).halfClosed(); in closeAfterClientHalfCloseShouldSucceed()
248 verify(serverListener).halfClosed(); in abortStreamAfterClientHalfCloseShouldCallClose()
|
| D | NettyServerHandlerTest.java | 268 verify(streamListener).halfClosed(); in inboundDataShouldForwardToStreamListener()
287 verify(streamListener).halfClosed(); in clientHalfCloseShouldForwardToStreamListener()
|
| D | NettyClientTransportTest.java | 742 public void halfClosed() { in halfClosed() method in NettyClientTransportTest.EchoServerStreamListener
|
| /external/grpc-grpc-java/core/src/main/java/io/grpc/inprocess/ |
| D | InProcessTransport.java | 553 serverStreamListener.halfClosed();
633 serverStreamListener.halfClosed();
|
| /external/grpc-grpc-java/testing/src/main/java/io/grpc/internal/testing/ |
| D | AbstractTransportTest.java | 1939 public void halfClosed() { in halfClosed() method in AbstractTransportTest.ServerStreamListenerBase
|