Searched refs:mockStream1 (Results 1 – 1 of 1) sorted by relevance
193 ClientStream mockStream1 = mock(ClientStream.class); in retry_everythingDrained() local196 doReturn(mockStream1).when(retriableStreamRecorder).newSubstream(0); in retry_everythingDrained()198 inOrder(retriableStreamRecorder, masterListener, mockStream1, mockStream2, mockStream3); in retry_everythingDrained()219 inOrder.verify(mockStream1).setAuthority(AUTHORITY); in retry_everythingDrained()220 inOrder.verify(mockStream1).setCompressor(COMPRESSOR); in retry_everythingDrained()221 inOrder.verify(mockStream1).setDecompressorRegistry(DECOMPRESSOR_REGISTRY); in retry_everythingDrained()222 inOrder.verify(mockStream1).setFullStreamDecompression(false); in retry_everythingDrained()223 inOrder.verify(mockStream1).setFullStreamDecompression(true); in retry_everythingDrained()224 inOrder.verify(mockStream1).setMaxInboundMessageSize(MAX_INBOUND_MESSAGE_SIZE); in retry_everythingDrained()225 inOrder.verify(mockStream1).setMessageCompression(true); in retry_everythingDrained()[all …]