Searched refs:clientStreamStatus (Results 1 – 1 of 1) sorted by relevance
477 Status clientStreamStatus = clientStreamListener.status.get(TIMEOUT_MS, TimeUnit.MILLISECONDS); in shutdownNowKillsServerStream() local478 assertFalse(clientStreamStatus.isOk()); in shutdownNowKillsServerStream()481 assertStatusEquals(clientStreamStatus, clientStreamTracer1.getStatus()); in shutdownNowKillsServerStream()809 Status clientStreamStatus = clientStreamListener.status.get(TIMEOUT_MS, TimeUnit.MILLISECONDS); in basicStream() local812 assertSame(clientStreamStatus, clientStreamTracer1.getStatus()); in basicStream()815 assertEquals(status.getCode(), clientStreamStatus.getCode()); in basicStream()816 assertEquals(status.getDescription(), clientStreamStatus.getDescription()); in basicStream()871 Status clientStreamStatus = clientStreamListener.status.get(TIMEOUT_MS, TimeUnit.MILLISECONDS); in zeroMessageStream() local873 assertEquals(status.getCode(), clientStreamStatus.getCode()); in zeroMessageStream()874 assertEquals(status.getDescription(), clientStreamStatus.getDescription()); in zeroMessageStream()[all …]