Searched refs:serverStreamListener (Results 1 – 4 of 4) sorted by relevance
377 ServerStreamListenerBase serverStreamListener = serverStreamCreation.listener; in openStreamPreventsTermination() local400 assertTrue(serverStreamListener.awaitHalfClosed(TIMEOUT_MS, TimeUnit.MILLISECONDS)); in openStreamPreventsTermination()428 ServerStreamListenerBase serverStreamListener = serverStreamCreation.listener; in shutdownNowKillsClientStream() local442 Status serverStatus = serverStreamListener.status.get(TIMEOUT_MS, TimeUnit.MILLISECONDS); in shutdownNowKillsClientStream()465 ServerStreamListenerBase serverStreamListener = serverStreamCreation.listener; in shutdownNowKillsServerStream() local488 assertNotNull(serverStreamListener.status.get(TIMEOUT_MS, TimeUnit.MILLISECONDS)); in shutdownNowKillsServerStream()702 ServerStreamListenerBase serverStreamListener = serverStreamCreation.listener; in basicStream() local719 InputStream message = serverStreamListener.messageQueue.poll(TIMEOUT_MS, TimeUnit.MILLISECONDS); in basicStream()732 assertNull("no additional message expected", serverStreamListener.messageQueue.poll()); in basicStream()735 assertTrue(serverStreamListener.awaitHalfClosed(TIMEOUT_MS, TimeUnit.MILLISECONDS)); in basicStream()[all …]
329 public void setListener(ServerStreamListener serverStreamListener) {330 clientStream.setListener(serverStreamListener);502 private ServerStreamListener serverStreamListener;521 this.serverStreamListener = listener;530 serverStreamListener.onReady();550 serverStreamListener.messagesAvailable(serverReceiveQueue.poll());554 serverStreamListener.halfClosed();577 serverStreamListener.messagesAvailable(producer);624 serverStreamListener.closed(serverListenerStatus);634 serverStreamListener.halfClosed();
88 void setListener(ServerStreamListener serverStreamListener); in setListener() argument
175 public final void setListener(ServerStreamListener serverStreamListener) { in setListener() argument176 transportState().setListener(serverStreamListener); in setListener()