Searched refs:serverTransportListener (Results 1 – 2 of 2) sorted by relevance
244 MockServerTransportListener serverTransportListener in frameAfterRstStreamShouldNotBreakClientChannel() local246 serverTransport = serverTransportListener.transport; in frameAfterRstStreamShouldNotBreakClientChannel()256 = serverTransportListener.takeStreamOrFail(TIMEOUT_MS, TimeUnit.MILLISECONDS); in frameAfterRstStreamShouldNotBreakClientChannel()278 = serverTransportListener.takeStreamOrFail(TIMEOUT_MS, TimeUnit.MILLISECONDS); in frameAfterRstStreamShouldNotBreakClientChannel()326 MockServerTransportListener serverTransportListener in clientStartAndStopOnceConnected() local332 assertTrue(serverTransportListener.waitForTermination(TIMEOUT_MS, TimeUnit.MILLISECONDS)); in clientStartAndStopOnceConnected()366 MockServerTransportListener serverTransportListener in openStreamPreventsTermination() local368 serverTransport = serverTransportListener.transport; in openStreamPreventsTermination()375 = serverTransportListener.takeStreamOrFail(TIMEOUT_MS, TimeUnit.MILLISECONDS); in openStreamPreventsTermination()404 assertFalse(serverTransportListener.isTerminated()); in openStreamPreventsTermination()[all …]
80 private ServerTransportListener serverTransportListener; field in InProcessTransport113 serverTransportListener = server.register(this); in start()115 if (serverTransportListener == null) { in start()137 serverStreamAttributes = serverTransportListener.transportReady(serverTransportAttrs); in start()265 if (serverTransportListener != null) {266 serverTransportListener.transportTerminated();658 serverTransportListener.streamCreated(serverStream, method.getFullMethodName(), headers);