Home
last modified time | relevance | path

Searched refs:streamListenerCaptor (Results 1 – 2 of 2) sorted by relevance

/external/grpc-grpc-java/core/src/test/java/io/grpc/internal/
DServerImplTest.java186 private ArgumentCaptor<ServerStreamListener> streamListenerCaptor; field in ServerImplTest
500 verify(stream).setListener(streamListenerCaptor.capture()); in basicExchangeHelper()
501 ServerStreamListener streamListener = streamListenerCaptor.getValue(); in basicExchangeHelper()
751 verify(stream).setListener(streamListenerCaptor.capture()); in exceptionInStartCallPropagatesToStream()
752 ServerStreamListener streamListener = streamListenerCaptor.getValue(); in exceptionInStartCallPropagatesToStream()
913 verify(stream).setListener(streamListenerCaptor.capture()); in testCallContextIsBoundInListenerCallbacks()
914 ServerStreamListener streamListener = streamListenerCaptor.getValue(); in testCallContextIsBoundInListenerCallbacks()
977 verify(stream).setListener(streamListenerCaptor.capture()); in testClientClose_setup()
978 ServerStreamListener streamListener = streamListenerCaptor.getValue(); in testClientClose_setup()
DManagedChannelImplTest.java211 private ArgumentCaptor<ClientStreamListener> streamListenerCaptor = field in ManagedChannelImplTest
657 verify(mockStream).start(streamListenerCaptor.capture()); in callOptionsExecutor()
660 ClientStreamListener streamListener = streamListenerCaptor.getValue(); in callOptionsExecutor()
2427 verify(mockStream).start(streamListenerCaptor.capture()); in channelsAndSubchannels_instrumented0()
2430 ClientStreamListener streamListener = streamListenerCaptor.getValue(); in channelsAndSubchannels_instrumented0()
2496 verify(mockStream).start(streamListenerCaptor.capture()); in channelsAndSubchannels_oob_instrumented0()
2499 ClientStreamListener streamListener = streamListenerCaptor.getValue(); in channelsAndSubchannels_oob_instrumented0()
2659 ArgumentCaptor<ClientStreamListener> streamListenerCaptor = in retryBackoffThenChannelShutdown_retryShouldStillHappen_newCallShouldFail() local
2661 verify(mockStream).start(streamListenerCaptor.capture()); in retryBackoffThenChannelShutdown_retryShouldStillHappen_newCallShouldFail()
2665 streamListenerCaptor.getValue().closed(Status.UNAVAILABLE, new Metadata()); in retryBackoffThenChannelShutdown_retryShouldStillHappen_newCallShouldFail()
[all …]