| /external/grpc-grpc-java/core/src/test/java/io/grpc/internal/ |
| D | DelayedStreamTest.java | 119 listenerCaptor.getValue().onReady(); in setStream_sendsAllMessages()
120 verify(listener).onReady(); in setStream_sendsAllMessages()
273 public void onReady() { in listener_onReadyDelayedUntilPassthrough() method in DelayedStreamTest.IsReadyListener
286 listener.onReady(); in listener_onReadyDelayedUntilPassthrough()
312 passedListener.onReady(); in listener_allQueued()
315 passedListener.onReady(); in listener_allQueued()
322 inOrder.verify(listener).onReady(); in listener_allQueued()
325 inOrder.verify(listener).onReady(); in listener_allQueued()
342 delayedListener.onReady(); in listener_noQueued()
343 verify(listener).onReady(); in listener_noQueued()
|
| D | ServerCallImplTest.java | 396 streamListener.onReady(); in streamListener_onReady()
398 verify(callListener).onReady(); in streamListener_onReady()
405 streamListener.onReady(); in streamListener_onReady_onlyOnce()
409 streamListener.onReady(); in streamListener_onReady_onlyOnce()
411 verify(callListener).onReady(); in streamListener_onReady_onlyOnce()
|
| D | NoopClientStreamListener.java | 30 public void onReady() {} in onReady() method in NoopClientStreamListener
|
| D | ServerImplTest.java | 868 public void onReady() { in testCallContextIsBoundInListenerCallbacks()
917 streamListener.onReady(); in testCallContextIsBoundInListenerCallbacks()
946 public void onReady() { in testClientClose_setup()
981 streamListener.onReady(); in testClientClose_setup()
1206 doThrow(expectedT).when(mockListener).onReady(); in onReady_errorCancelsCall()
1207 listener.onReady(); in onReady_errorCancelsCall()
1229 doThrow(expectedT).when(mockListener).onReady(); in onReady_runtimeExceptionCancelsCall()
1230 listener.onReady(); in onReady_runtimeExceptionCancelsCall()
|
| D | AbstractServerStreamTest.java | 208 verify(streamListener).onReady(); in listenerReady_readyCalled()
347 public void onReady() {} in onReady() method in AbstractServerStreamTest.ServerStreamListenerBase
|
| D | ClientCallImplTest.java | 253 doThrow(failure).when(callListener).onReady(); in exceptionInOnReadyTakesPrecedenceOverServer()
261 streamListener.onReady(); in exceptionInOnReadyTakesPrecedenceOverServer()
547 public void onReady() { in callerContextPropagatedToListener()
563 listener.onReady(); in callerContextPropagatedToListener()
902 streamListener.onReady(); in cancelInOnMessageShouldInvokeStreamCancel()
|
| /external/grpc-grpc-java/core/src/main/java/io/grpc/ |
| D | PartialForwardingServerCallListener.java | 49 public void onReady() { in onReady() method in PartialForwardingServerCallListener
50 delegate().onReady(); in onReady()
|
| D | PartialForwardingClientCallListener.java | 43 public void onReady() { in onReady() method in PartialForwardingClientCallListener
44 delegate().onReady(); in onReady()
|
| D | Contexts.java | 113 public void onReady() { in onReady() method in Contexts.ContextualizedServerCallListener
116 super.onReady(); in onReady()
|
| D | ClientCall.java | 156 public void onReady() {} in onReady() method in ClientCall.Listener
|
| D | ServerCall.java | 91 public void onReady() {} in onReady() method in ServerCall.Listener
|
| /external/grpc-grpc-java/core/src/main/java/io/grpc/internal/ |
| D | ForwardingClientStreamListener.java | 48 public void onReady() { in onReady() method in ForwardingClientStreamListener
49 delegate().onReady(); in onReady()
|
| D | DelayedStream.java | 401 public void onReady() { in onReady() method in DelayedStream.DelayedStreamListener
403 realListener.onReady(); in onReady()
408 realListener.onReady(); in onReady()
|
| D | StreamListener.java | 46 void onReady(); in onReady() method
|
| D | ServerCallImpl.java | 303 public void onReady() { in onReady() method in ServerCallImpl.ServerStreamListenerImpl
307 listener.onReady(); in onReady()
|
| D | ServerImpl.java | 625 public void onReady() {} in onReady() method in ServerImpl.NoopListener
749 public void onReady() { in onReady() method in ServerImpl.JumpToApplicationThreadServerStreamListener
758 getListener().onReady(); in onReady()
|
| D | AbstractStream.java | 298 listener().onReady();
|
| /external/grpc-grpc-java/core/src/test/java/io/grpc/ |
| D | ContextsTest.java | 81 @Override public void onReady() { in interceptCall_basic()
103 wrapped.onReady(); in interceptCall_basic()
145 @Override public void onReady() { in interceptCall_restoresIfListenerThrows()
179 wrapped.onReady(); in interceptCall_restoresIfListenerThrows()
|
| /external/grpc-grpc-java/core/src/main/java/io/grpc/inprocess/ |
| D | InProcessTransport.java | 334 boolean onReady = clientStream.serverRequested(numMessages);
335 if (onReady) {
338 clientStreamListener.onReady();
525 boolean onReady = serverStream.clientRequested(numMessages);
526 if (onReady) {
529 serverStreamListener.onReady();
|
| /external/grpc-grpc-java/netty/src/test/java/io/grpc/netty/ |
| D | NettyStreamTestBase.java | 158 verify(listener()).onReady(); in notifiedOnReadyAfterWriteCompletes()
173 verify(listener(), never()).onReady(); in shouldBeReadyForDataAfterWritingSmallMessage()
188 verify(listener(), never()).onReady(); in shouldNotBeReadyForDataAfterWritingLargeMessage()
|
| D | NettyServerStreamTest.java | 80 verify(listener()).onReady(); in setUp()
295 verify(serverListener, atLeastOnce()).onReady(); in createStream()
|
| /external/grpc-grpc-java/stub/src/main/java/io/grpc/stub/ |
| D | ServerCalls.java | 176 onReady(); in onHalfClose()
189 public void onReady() { in onReady() method in ServerCalls.UnaryServerCallHandler.UnaryServerCallListener
277 public void onReady() { in onReady() method in ServerCalls.StreamingServerCallHandler.StreamingServerCallListener
|
| /external/grpc-grpc-java/core/src/main/java/io/grpc/util/ |
| D | TransmitStatusRuntimeExceptionInterceptor.java | 99 public void onReady() { in interceptCall() method
101 super.onReady(); in interceptCall()
|
| /external/grpc-grpc-java/core/src/test/java/io/grpc/util/ |
| D | UtilServerInterceptorsTest.java | 104 public void onReady() { in statusRuntimeExceptionTransmitter()
118 getSoleMethod(intercepted).getServerCallHandler().startCall(call, headers).onReady(); in statusRuntimeExceptionTransmitter()
|
| /external/grpc-grpc-java/stub/src/test/java/io/grpc/stub/ |
| D | ServerCallsTest.java | 122 callListener.onReady(); in runtimeStreamObserverIsServerCallStreamObserver()
232 callListener.onReady(); in disablingInboundAutoFlowControlSuppressesRequestsForMoreMessages()
280 callListener.onReady(); in onReadyHandlerCalledForUnaryRequest()
290 callListener.onReady(); in onReadyHandlerCalledForUnaryRequest()
|