Home
last modified time | relevance | path

Searched defs:streamListener (Results 1 – 9 of 9) sorted by relevance

/external/grpc-grpc-java/core/src/test/java/io/grpc/internal/
DServerCallImplTest.java346 ServerStreamListenerImpl<Long> streamListener = in streamListener_halfClosed() local
356 ServerStreamListenerImpl<Long> streamListener = in streamListener_halfClosed_onlyOnce() local
369 ServerStreamListenerImpl<Long> streamListener = in streamListener_closedOk() local
381 ServerStreamListenerImpl<Long> streamListener = in streamListener_closedCancelled() local
393 ServerStreamListenerImpl<Long> streamListener = in streamListener_onReady() local
403 ServerStreamListenerImpl<Long> streamListener = in streamListener_onReady_onlyOnce() local
416 ServerStreamListenerImpl<Long> streamListener = in streamListener_messageRead() local
425 ServerStreamListenerImpl<Long> streamListener = in streamListener_messageRead_onlyOnce() local
438 ServerStreamListenerImpl<Long> streamListener = in streamListener_unexpectedRuntimeException() local
DClientCallImplTest.java101 @Mock private ClientStreamListener streamListener; field in ClientCallImplTest
156 final ClientStreamListener streamListener = listenerArgumentCaptor.getValue(); in statusPropagatedFromStreamToCallListener() local
178 final ClientStreamListener streamListener = listenerArgumentCaptor.getValue(); in exceptionInOnMessageTakesPrecedenceOverServer() local
215 final ClientStreamListener streamListener = listenerArgumentCaptor.getValue(); in exceptionInOnHeadersTakesPrecedenceOverServer() local
250 final ClientStreamListener streamListener = listenerArgumentCaptor.getValue(); in exceptionInOnReadyTakesPrecedenceOverServer() local
901 ClientStreamListener streamListener = listenerArgumentCaptor.getValue(); in cancelInOnMessageShouldInvokeStreamCancel() local
DServerImplTest.java501 ServerStreamListener streamListener = streamListenerCaptor.getValue(); in basicExchangeHelper() local
752 ServerStreamListener streamListener = streamListenerCaptor.getValue(); in exceptionInStartCallPropagatesToStream() local
914 ServerStreamListener streamListener = streamListenerCaptor.getValue(); in testCallContextIsBoundInListenerCallbacks() local
978 ServerStreamListener streamListener = streamListenerCaptor.getValue(); in testClientClose_setup() local
993 ServerStreamListener streamListener = testClientClose_setup(callReference, in testClientClose_cancelTriggersImmediateCancellation() local
1016 ServerStreamListener streamListener = testClientClose_setup(callReference, in testClientClose_OkTriggersDelayedCancellation() local
DAbstractServerStreamTest.java204 ServerStreamListener streamListener = mock(ServerStreamListener.class); in listenerReady_readyCalled() local
DDelayedClientTransportTest.java76 @Mock private ClientStreamListener streamListener; field in DelayedClientTransportTest
DManagedChannelImplTest.java660 ClientStreamListener streamListener = streamListenerCaptor.getValue(); in callOptionsExecutor() local
2430 ClientStreamListener streamListener = streamListenerCaptor.getValue(); in channelsAndSubchannels_instrumented0() local
2499 ClientStreamListener streamListener = streamListenerCaptor.getValue(); in channelsAndSubchannels_oob_instrumented0() local
/external/grpc-grpc-java/netty/src/test/java/io/grpc/netty/
DNettyServerHandlerTest.java119 private ServerStreamListener streamListener; field in NettyServerHandlerTest
DNettyClientHandlerTest.java129 private ClientStreamListener streamListener; field in NettyClientHandlerTest
/external/grpc-grpc-java/okhttp/src/test/java/io/grpc/okhttp/
DOkHttpClientTransportTest.java1527 MockStreamListener streamListener = new MockStreamListener(); in unreachableServer() local