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.java210 private ArgumentCaptor<ClientStreamListener> streamListenerCaptor = field in ManagedChannelImplTest
656 verify(mockStream).start(streamListenerCaptor.capture()); in callOptionsExecutor()
659 ClientStreamListener streamListener = streamListenerCaptor.getValue(); in callOptionsExecutor()
2428 verify(mockStream).start(streamListenerCaptor.capture()); in channelsAndSubchannels_instrumented0()
2431 ClientStreamListener streamListener = streamListenerCaptor.getValue(); in channelsAndSubchannels_instrumented0()
2497 verify(mockStream).start(streamListenerCaptor.capture()); in channelsAndSubchannels_oob_instrumented0()
2500 ClientStreamListener streamListener = streamListenerCaptor.getValue(); in channelsAndSubchannels_oob_instrumented0()
2660 ArgumentCaptor<ClientStreamListener> streamListenerCaptor = in retryBackoffThenChannelShutdown_retryShouldStillHappen_newCallShouldFail() local
2662 verify(mockStream).start(streamListenerCaptor.capture()); in retryBackoffThenChannelShutdown_retryShouldStillHappen_newCallShouldFail()
2666 streamListenerCaptor.getValue().closed(Status.UNAVAILABLE, new Metadata()); in retryBackoffThenChannelShutdown_retryShouldStillHappen_newCallShouldFail()
[all …]