Searched refs:mockStream (Results 1 – 3 of 3) sorted by relevance
1229 ClientStream mockStream = mock(ClientStream.class); in throttledStream_FailWithRetriableStatusCode_WithoutPushback() local1230 doReturn(mockStream).when(retriableStreamRecorder).newSubstream(anyInt()); in throttledStream_FailWithRetriableStatusCode_WithoutPushback()1234 verify(mockStream).start(sublistenerCaptor.capture()); in throttledStream_FailWithRetriableStatusCode_WithoutPushback()1249 ClientStream mockStream = mock(ClientStream.class); in throttledStream_FailWithNonRetriableStatusCode_WithoutPushback() local1250 doReturn(mockStream).when(retriableStreamRecorder).newSubstream(anyInt()); in throttledStream_FailWithNonRetriableStatusCode_WithoutPushback()1254 verify(mockStream).start(sublistenerCaptor.capture()); in throttledStream_FailWithNonRetriableStatusCode_WithoutPushback()1271 ClientStream mockStream = mock(ClientStream.class); in throttledStream_FailWithRetriableStatusCode_WithRetriablePushback() local1272 doReturn(mockStream).when(retriableStreamRecorder).newSubstream(anyInt()); in throttledStream_FailWithRetriableStatusCode_WithRetriablePushback()1276 verify(mockStream).start(sublistenerCaptor.capture()); in throttledStream_FailWithRetriableStatusCode_WithRetriablePushback()1294 ClientStream mockStream = mock(ClientStream.class); in throttledStream_FailWithNonRetriableStatusCode_WithRetriablePushback() local[all …]
66 private ClientStream mockStream; field in CallCredentialsApplyingTest111 .thenReturn(mockStream); in setUp()212 assertSame(mockStream, stream); in applyMetadata_inline()255 assertSame(mockStream, stream.getRealStream()); in applyMetadata_delayed()285 assertSame(mockStream, stream); in noCreds()
431 ClientStream mockStream = mock(ClientStream.class); in subtestCallsAndShutdown() local447 .thenReturn(mockStream); in subtestCallsAndShutdown()518 verify(mockStream).start(any(ClientStreamListener.class)); in subtestCallsAndShutdown()626 ClientStream mockStream = mock(ClientStream.class); in callOptionsExecutor() local647 .thenReturn(mockStream); in callOptionsExecutor()657 verify(mockStream).start(streamListenerCaptor.capture()); in callOptionsExecutor()1491 ClientStream mockStream = mock(ClientStream.class); in pickerReturnsStreamTracer_noDelay() local1502 .thenReturn(mockStream); in pickerReturnsStreamTracer_noDelay()1524 ClientStream mockStream = mock(ClientStream.class); in pickerReturnsStreamTracer_delayed() local1540 .thenReturn(mockStream); in pickerReturnsStreamTracer_delayed()[all …]