Searched refs:mockStream3 (Results 1 – 1 of 1) sorted by relevance
195 ClientStream mockStream3 = mock(ClientStream.class); in retry_everythingDrained() local198 inOrder(retriableStreamRecorder, masterListener, mockStream1, mockStream2, mockStream3); in retry_everythingDrained()294 doReturn(mockStream3).when(retriableStreamRecorder).newSubstream(2); in retry_everythingDrained()311 inOrder.verify(mockStream3).setAuthority(AUTHORITY); in retry_everythingDrained()312 inOrder.verify(mockStream3).setCompressor(COMPRESSOR); in retry_everythingDrained()313 inOrder.verify(mockStream3).setDecompressorRegistry(DECOMPRESSOR_REGISTRY); in retry_everythingDrained()314 inOrder.verify(mockStream3).setFullStreamDecompression(false); in retry_everythingDrained()315 inOrder.verify(mockStream3).setFullStreamDecompression(true); in retry_everythingDrained()316 inOrder.verify(mockStream3).setMaxInboundMessageSize(MAX_INBOUND_MESSAGE_SIZE); in retry_everythingDrained()317 inOrder.verify(mockStream3).setMessageCompression(true); in retry_everythingDrained()[all …]