Home
last modified time | relevance | path

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

/aosp_15_r20/external/grpc-grpc-java/okhttp/src/test/java/io/grpc/okhttp/
H A DOkHttpServerTransportTest.java203 MockStreamListener streamListener = mockTransportListener.newStreams.pop(); in maxConnectionIdleTimer() local
353 MockStreamListener streamListener = mockTransportListener.newStreams.pop(); in basicRpc_succeeds() local
420 MockStreamListener streamListener = mockTransportListener.newStreams.pop(); in activeRpc_delaysShutdownTermination() local
650 MockStreamListener streamListener = mockTransportListener.newStreams.pop(); in trailersAfterEndStream_failsWithRst() local
673 MockStreamListener streamListener = mockTransportListener.newStreams.pop(); in trailers_endStream() local
710 MockStreamListener streamListener = mockTransportListener.newStreams.pop(); in headersInMiddleOfRequest_failsWithRst() local
753 MockStreamListener streamListener = mockTransportListener.newStreams.pop(); in hostWithoutAuthority_usesHost() local
775 MockStreamListener streamListener = mockTransportListener.newStreams.pop(); in authorityAndHost_usesAuthority() local
795 MockStreamListener streamListener = mockTransportListener.newStreams.pop(); in missingAuthorityAndHost_hasNullAuthority() local
1048 MockStreamListener streamListener = mockTransportListener.newStreams.pop(); in dataAfterHalfClose_failsWithRst() local
[all …]
H A DOkHttpClientTransportTest.java1716 MockStreamListener streamListener = new MockStreamListener(); in unreachableServer() local
/aosp_15_r20/external/grpc-grpc-java/core/src/test/java/io/grpc/internal/
H A DServerCallImplTest.java385 ServerStreamListenerImpl<Long> streamListener = in streamListener_halfClosed() local
395 ServerStreamListenerImpl<Long> streamListener = in streamListener_halfClosed_onlyOnce() local
408 ServerStreamListenerImpl<Long> streamListener = in streamListener_closedOk() local
423 ServerStreamListenerImpl<Long> streamListener = in streamListener_closedCancelled() local
435 ServerStreamListenerImpl<Long> streamListener = in streamListener_onReady() local
445 ServerStreamListenerImpl<Long> streamListener = in streamListener_onReady_onlyOnce() local
458 ServerStreamListenerImpl<Long> streamListener = in streamListener_messageRead() local
467 ServerStreamListenerImpl<Long> streamListener = in streamListener_messageRead_onlyOnce() local
480 ServerStreamListenerImpl<Long> streamListener = in streamListener_unexpectedRuntimeException() local
H A DClientCallImplTest.java178 final ClientStreamListener streamListener = listenerArgumentCaptor.getValue(); in statusPropagatedFromStreamToCallListener() local
199 final ClientStreamListener streamListener = listenerArgumentCaptor.getValue(); in exceptionInOnMessageTakesPrecedenceOverServer() local
236 final ClientStreamListener streamListener = listenerArgumentCaptor.getValue(); in exceptionInOnHeadersTakesPrecedenceOverServer() local
297 final ClientStreamListener streamListener = listenerArgumentCaptor.getValue(); in exceptionInOnHeadersHasOnCloseQueuedLast() local
315 final ClientStreamListener streamListener = listenerArgumentCaptor.getValue(); in exceptionInOnReadyTakesPrecedenceOverServer() local
1013 ClientStreamListener streamListener = listenerArgumentCaptor.getValue(); in cancelInOnMessageShouldInvokeStreamCancel() local
H A DServerImplTest.java657 ServerStreamListener streamListener = streamListenerCaptor.getValue(); in basicExchangeHelper() local
910 ServerStreamListener streamListener = streamListenerCaptor.getValue(); in exceptionInStartCallPropagatesToStream() local
1072 ServerStreamListener streamListener = streamListenerCaptor.getValue(); in testCallContextIsBoundInListenerCallbacks() local
1140 ServerStreamListener streamListener = streamListenerCaptor.getValue(); in testStreamClose_setup() local
1174 ServerStreamListener streamListener = testStreamClose_setup(callReference, in testStreamClose_clientCancelTriggersImmediateCancellation() local
1197 ServerStreamListener streamListener = testStreamClose_setup(callReference, in testStreamClose_clientOkTriggersDelayedCancellation() local
H A DAbstractServerStreamTest.java246 ServerStreamListener streamListener = mock(ServerStreamListener.class); in listenerReady_readyCalled() local
H A DDelayedClientTransportTest.java86 @Mock private ClientStreamListener streamListener; field in DelayedClientTransportTest
H A DManagedChannelImplTest.java1035 ClientStreamListener streamListener = streamListenerCaptor.getValue(); in callOptionsExecutor() local
3286 ClientStreamListener streamListener = streamListenerCaptor.getValue(); in channelsAndSubchannels_instrumented0() local
3359 ClientStreamListener streamListener = streamListenerCaptor.getValue(); in channelsAndSubchannels_oob_instrumented0() local
/aosp_15_r20/prebuilts/go/linux-x86/src/net/
Dmockserver_test.go159 type streamListener struct { struct
160 network, address string
161 Listener
162 done chan bool // signal that indicates server stopped
165 func (sl *streamListener) newLocalServer() *localServer {
/aosp_15_r20/external/grpc-grpc-java/binder/src/androidTest/java/io/grpc/binder/internal/
H A DBinderClientTransportTest.java96 private final TestStreamListener streamListener = new TestStreamListener(); field in BinderClientTransportTest
/aosp_15_r20/external/grpc-grpc-java/netty/src/test/java/io/grpc/netty/
H A DNettyServerHandlerTest.java123 private ServerStreamListener streamListener; field in NettyServerHandlerTest
H A DNettyClientHandlerTest.java142 private ClientStreamListener streamListener; field in NettyClientHandlerTest
/aosp_15_r20/prebuilts/checkstyle/
HDcheckstyle.jarMETA-INF/MANIFEST.MF META-INF/ com/ com/puppycrawl/ com/ ...