Searched refs:clientStreamTracer1 (Results 1 – 1 of 1) sorted by relevance
171 private final TestClientStreamTracer clientStreamTracer1 = new TestClientStreamTracer(); field in AbstractTransportTest186 .thenReturn(clientStreamTracer1) in setUp()444 assertTrue(clientStreamTracer1.await(TIMEOUT_MS, TimeUnit.MILLISECONDS)); in shutdownNowKillsClientStream()445 assertStatusEquals(status, clientStreamTracer1.getStatus()); in shutdownNowKillsClientStream()480 assertTrue(clientStreamTracer1.await(TIMEOUT_MS, TimeUnit.MILLISECONDS)); in shutdownNowKillsServerStream()481 assertStatusEquals(clientStreamStatus, clientStreamTracer1.getStatus()); in shutdownNowKillsServerStream()610 assertSame(shutdownReason, clientStreamTracer1.getStatus()); in newStream_afterTermination()695 assertTrue(clientStreamTracer1.awaitOutboundHeaders(TIMEOUT_MS, TimeUnit.MILLISECONDS)); in basicStream()716 assertThat(clientStreamTracer1.nextOutboundEvent()).isEqualTo("outboundMessage(0)"); in basicStream()722 assertThat(clientStreamTracer1.nextOutboundEvent()) in basicStream()[all …]