Home
last modified time | relevance | path

Searched refs: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
349 streamListener.halfClosed(); in streamListener_halfClosed()
356 ServerStreamListenerImpl<Long> streamListener = in streamListener_halfClosed_onlyOnce() local
358 streamListener.halfClosed(); in streamListener_halfClosed_onlyOnce()
360 streamListener.closed(Status.CANCELLED); in streamListener_halfClosed_onlyOnce()
362 streamListener.halfClosed(); in streamListener_halfClosed_onlyOnce()
369 ServerStreamListenerImpl<Long> streamListener = in streamListener_closedOk() local
372 streamListener.closed(Status.OK); in streamListener_closedOk()
381 ServerStreamListenerImpl<Long> streamListener = in streamListener_closedCancelled() local
384 streamListener.closed(Status.CANCELLED); in streamListener_closedCancelled()
[all …]
DDelayedClientTransportTest.java76 @Mock private ClientStreamListener streamListener; field in DelayedClientTransportTest
125 stream.start(streamListener); in streamStartThenAssignTransport()
136 verifyNoMoreInteractions(streamListener); in streamStartThenAssignTransport()
138 verify(streamListener).onReady(); in streamStartThenAssignTransport()
139 verifyNoMoreInteractions(streamListener); in streamStartThenAssignTransport()
153 stream.start(streamListener); in newStreamThenAssignTransportThenShutdown()
154 verify(mockRealStream).start(same(streamListener)); in newStreamThenAssignTransportThenShutdown()
200 stream.start(streamListener); in startThenCancelStreamWithoutSetTransport()
204 verify(streamListener).closed(same(Status.CANCELLED), any(Metadata.class)); in startThenCancelStreamWithoutSetTransport()
211 stream.start(streamListener); in newStreamThenShutdownTransportThenAssignTransport()
[all …]
DClientCallImplTest.java101 @Mock private ClientStreamListener streamListener; field in ClientCallImplTest
156 final ClientStreamListener streamListener = listenerArgumentCaptor.getValue(); in statusPropagatedFromStreamToCallListener() local
157 streamListener.headersRead(new Metadata()); in statusPropagatedFromStreamToCallListener()
159 streamListener.closed(status , new Metadata()); in statusPropagatedFromStreamToCallListener()
178 final ClientStreamListener streamListener = listenerArgumentCaptor.getValue(); in exceptionInOnMessageTakesPrecedenceOverServer() local
179 streamListener.headersRead(new Metadata()); in exceptionInOnMessageTakesPrecedenceOverServer()
190 streamListener in exceptionInOnMessageTakesPrecedenceOverServer()
192 streamListener.closed(Status.OK, new Metadata()); in exceptionInOnMessageTakesPrecedenceOverServer()
215 final ClientStreamListener streamListener = listenerArgumentCaptor.getValue(); in exceptionInOnHeadersTakesPrecedenceOverServer() local
226 streamListener.headersRead(new Metadata()); in exceptionInOnHeadersTakesPrecedenceOverServer()
[all …]
DServerImplTest.java501 ServerStreamListener streamListener = streamListenerCaptor.getValue(); in basicExchangeHelper() local
502 assertNotNull(streamListener); in basicExchangeHelper()
520 streamListener.messagesAvailable(new SingleMessageProducer(STRING_MARSHALLER.stream(request))); in basicExchangeHelper()
536 streamListener.halfClosed(); // All full; no dessert. in basicExchangeHelper()
554 streamListener.closed(Status.OK); in basicExchangeHelper()
752 ServerStreamListener streamListener = streamListenerCaptor.getValue(); in exceptionInStartCallPropagatesToStream() local
753 assertNotNull(streamListener); in exceptionInStartCallPropagatesToStream()
914 ServerStreamListener streamListener = streamListenerCaptor.getValue(); in testCallContextIsBoundInListenerCallbacks() local
915 assertNotNull(streamListener); in testCallContextIsBoundInListenerCallbacks()
917 streamListener.onReady(); in testCallContextIsBoundInListenerCallbacks()
[all …]
DAbstractServerStreamTest.java204 ServerStreamListener streamListener = mock(ServerStreamListener.class); in listenerReady_readyCalled() local
205 stream.transportState().setListener(streamListener); in listenerReady_readyCalled()
208 verify(streamListener).onReady(); in listenerReady_readyCalled()
DManagedChannelImplTest.java660 ClientStreamListener streamListener = streamListenerCaptor.getValue(); in callOptionsExecutor() local
663 streamListener.closed(Status.CANCELLED, trailers); in callOptionsExecutor()
2430 ClientStreamListener streamListener = streamListenerCaptor.getValue(); in channelsAndSubchannels_instrumented0() local
2436 streamListener.closed(success ? Status.OK : Status.UNKNOWN, new Metadata()); in channelsAndSubchannels_instrumented0()
2499 ClientStreamListener streamListener = streamListenerCaptor.getValue(); in channelsAndSubchannels_oob_instrumented0() local
2505 streamListener.closed(success ? Status.OK : Status.UNKNOWN, new Metadata()); in channelsAndSubchannels_oob_instrumented0()
/external/grpc-grpc-java/netty/src/test/java/io/grpc/netty/
DNettyClientHandlerTest.java129 private ClientStreamListener streamListener; field in NettyClientHandlerTest
158 .when(streamListener) in setUp()
174 streamTransportState.setListener(streamListener); in setUp()
202 verify(streamListener).closed(eq(Status.CANCELLED), same(PROCESSED), any(Metadata.class)); in cancelBufferedStreamShouldChangeClientStreamStatus()
312 verify(streamListener).headersRead(captor.capture()); in inboundShouldForwardToStream()
344 verify(streamListener).closed(any(Status.class), eq(REFUSED), any(Metadata.class)); in receivedGoAwayShouldRefuseLaterStreamId()
352 verify(streamListener, never()) in receivedGoAwayShouldNotAffectEarlyStreamId()
354 verify(streamListener, never()) in receivedGoAwayShouldNotAffectEarlyStreamId()
363 verify(streamListener).closed(any(Status.class), eq(REFUSED), any(Metadata.class)); in receivedResetWithRefuseCode()
371 verify(streamListener).closed(any(Status.class), eq(PROCESSED), any(Metadata.class)); in receivedResetWithCanceCode()
[all …]
DNettyServerHandlerTest.java119 private ServerStreamListener streamListener; field in NettyServerHandlerTest
147 stream.setListener(streamListener); in streamCreated()
180 .when(streamListener) in setUp()
260 verify(streamListener, atLeastOnce()) in inboundDataShouldForwardToStreamListener()
268 verify(streamListener).halfClosed(); in inboundDataShouldForwardToStreamListener()
270 verify(streamListener, atLeastOnce()).onReady(); in inboundDataShouldForwardToStreamListener()
271 verifyNoMoreInteractions(streamListener); in inboundDataShouldForwardToStreamListener()
282 verify(streamListener, atLeastOnce()) in clientHalfCloseShouldForwardToStreamListener()
287 verify(streamListener).halfClosed(); in clientHalfCloseShouldForwardToStreamListener()
288 verify(streamListener, atLeastOnce()).onReady(); in clientHalfCloseShouldForwardToStreamListener()
[all …]
/external/grpc-grpc-java/okhttp/src/test/java/io/grpc/okhttp/
DOkHttpClientTransportTest.java1527 MockStreamListener streamListener = new MockStreamListener(); in unreachableServer() local
1528 clientTransport.newStream(method, new Metadata(), CallOptions.DEFAULT).start(streamListener); in unreachableServer()
1529 streamListener.waitUntilStreamClosed(); in unreachableServer()
1530 assertEquals(Status.UNAVAILABLE.getCode(), streamListener.status.getCode()); in unreachableServer()