Home
last modified time | relevance | path

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

/external/grpc-grpc-java/core/src/test/java/io/grpc/internal/
DRetriableStreamTest.java194 ClientStream mockStream2 = mock(ClientStream.class); in retry_everythingDrained() local
198 inOrder(retriableStreamRecorder, masterListener, mockStream1, mockStream2, mockStream3); in retry_everythingDrained()
250 doReturn(mockStream2).when(retriableStreamRecorder).newSubstream(1); in retry_everythingDrained()
264 inOrder.verify(mockStream2).setAuthority(AUTHORITY); in retry_everythingDrained()
265 inOrder.verify(mockStream2).setCompressor(COMPRESSOR); in retry_everythingDrained()
266 inOrder.verify(mockStream2).setDecompressorRegistry(DECOMPRESSOR_REGISTRY); in retry_everythingDrained()
267 inOrder.verify(mockStream2).setFullStreamDecompression(false); in retry_everythingDrained()
268 inOrder.verify(mockStream2).setFullStreamDecompression(true); in retry_everythingDrained()
269 inOrder.verify(mockStream2).setMaxInboundMessageSize(MAX_INBOUND_MESSAGE_SIZE); in retry_everythingDrained()
270 inOrder.verify(mockStream2).setMessageCompression(true); in retry_everythingDrained()
[all …]
DManagedChannelImplTest.java432 ClientStream mockStream2 = mock(ClientStream.class); in subtestCallsAndShutdown() local
449 .thenReturn(mockStream2); in subtestCallsAndShutdown()
473 verify(mockStream2).start(any(ClientStreamListener.class)); in subtestCallsAndShutdown()
2653 ClientStream mockStream2 = mock(ClientStream.class); in retryBackoffThenChannelShutdown_retryShouldStillHappen_newCallShouldFail() local
2655 .thenReturn(mockStream).thenReturn(mockStream2); in retryBackoffThenChannelShutdown_retryShouldStillHappen_newCallShouldFail()
2670 verify(mockStream2, never()).start(any(ClientStreamListener.class)); in retryBackoffThenChannelShutdown_retryShouldStillHappen_newCallShouldFail()
2689 verify(mockStream2).start(streamListenerCaptor.capture()); in retryBackoffThenChannelShutdown_retryShouldStillHappen_newCallShouldFail()