Home
last modified time | relevance | path

Searched refs:serverListener (Results 1 – 7 of 7) sorted by relevance

/external/okhttp/okhttp-ws-tests/src/test/java/com/squareup/okhttp/internal/ws/
DRealWebSocketTest.java62 private final WebSocketRecorder serverListener = new WebSocketRecorder(); field in RealWebSocketTest
82 serverExecutor, serverListener, url) { in setUp()
94 serverListener.assertExhausted(); in tearDown()
109 serverListener.assertTextMessage("Hello!"); in textMessage()
115 serverListener.assertBinaryMessage(new byte[] { 'H', 'e', 'l', 'l', 'o', '!' }); in binaryMessage()
153 serverListener.assertTextMessage("Hello!"); in streamingMessage()
172 serverListener.assertTextMessage("Hello!"); in streamingMessageCanInterleavePing()
187 serverListener.assertPong(new Buffer().writeUtf8("Hello!")); in unsolicitedPong()
193 serverListener.assertClose(1000, "Hello!"); in close()
343 serverListener.assertClose(1000, "Hello!"); in clientCloseClosesConnection()
[all …]
/external/grpc-grpc-java/testing/src/main/java/io/grpc/internal/testing/
DAbstractTransportTest.java166 private MockServerListener serverListener = new MockServerListener(); field in AbstractTransportTest
204 assertTrue(serverListener.waitForShutdown(TIMEOUT_MS, TimeUnit.MILLISECONDS)); in tearDown()
241 server.start(serverListener); in frameAfterRstStreamShouldNotBreakClientChannel()
245 = serverListener.takeListenerOrFail(TIMEOUT_MS, TimeUnit.MILLISECONDS); in frameAfterRstStreamShouldNotBreakClientChannel()
288 server.start(serverListener); in serverNotListening()
291 assertTrue(serverListener.waitForShutdown(TIMEOUT_MS, TimeUnit.MILLISECONDS)); in serverNotListening()
307 server.start(serverListener); in clientStartStop()
321 server.start(serverListener); in clientStartAndStopOnceConnected()
327 = serverListener.takeListenerOrFail(TIMEOUT_MS, TimeUnit.MILLISECONDS); in clientStartAndStopOnceConnected()
334 assertTrue(serverListener.waitForShutdown(TIMEOUT_MS, TimeUnit.MILLISECONDS)); in clientStartAndStopOnceConnected()
[all …]
/external/grpc-grpc-java/netty/src/test/java/io/grpc/netty/
DNettyServerStreamTest.java66 protected ServerStreamListener serverListener; field in NettyServerStreamTest
96 .when(serverListener) in setUp()
163 verifyZeroInteractions(serverListener); in closeBeforeClientHalfCloseShouldSucceed()
168 verify(serverListener).closed(Status.OK); in closeBeforeClientHalfCloseShouldSucceed()
191 verifyZeroInteractions(serverListener); in closeWithErrorBeforeClientHalfCloseShouldSucceed()
195 verify(serverListener).closed(Status.OK); in closeWithErrorBeforeClientHalfCloseShouldSucceed()
211 verify(serverListener).halfClosed(); in closeAfterClientHalfCloseShouldSucceed()
228 verify(serverListener).closed(Status.OK); in closeAfterClientHalfCloseShouldSucceed()
236 verify(serverListener).closed(same(status)); in abortStreamAndNotSendStatus()
248 verify(serverListener).halfClosed(); in abortStreamAfterClientHalfCloseShouldCallClose()
[all …]
DNettyClientTransportTest.java109 private final EchoServerListener serverListener = new EchoServerListener(); field in NettyClientTransportTest
161 assertEquals(1, serverListener.streamListeners.size()); in addDefaultUserAgent()
163 Metadata headers = serverListener.streamListeners.get(0).headers; in addDefaultUserAgent()
198 assertEquals(1, serverListener.streamListeners.size()); in overrideDefaultUserAgent()
199 Metadata receivedHeaders = serverListener.streamListeners.get(0).headers; in overrideDefaultUserAgent()
382 serverListener.transports.get(0).channel().pipeline().firstContext().close(); in bufferedStreamsShouldBeClosedWhenConnectionTerminates()
619 server.start(serverListener); in startServer()
/external/okhttp/okhttp-ws-tests/src/test/java/com/squareup/okhttp/ws/
DWebSocketCallTest.java54 WebSocketListener serverListener = new EmptyWebSocketListener(); in clientPingPong() local
55 server.enqueue(new MockResponse().withWebSocketUpgrade(serverListener)); in clientPingPong()
63 WebSocketRecorder serverListener = new WebSocketRecorder(); in clientMessage() local
64 server.enqueue(new MockResponse().withWebSocketUpgrade(serverListener)); in clientMessage()
68 serverListener.assertTextMessage("Hello, WebSockets!"); in clientMessage()
72 WebSocketListener serverListener = new EmptyWebSocketListener() { in serverMessage() local
85 server.enqueue(new MockResponse().withWebSocketUpgrade(serverListener)); in serverMessage()
192 WebSocketRecorder serverListener = new WebSocketRecorder(); in websocketScheme() local
193 server.enqueue(new MockResponse().withWebSocketUpgrade(serverListener)); in websocketScheme()
201 serverListener.assertTextMessage("abc"); in websocketScheme()
/external/grpc-grpc-java/core/src/main/java/io/grpc/inprocess/
DInProcessServer.java68 public void start(ServerListener serverListener) throws IOException { in start() argument
69 this.listener = serverListener; in start()
/external/grpc-grpc-java/netty/src/main/java/io/grpc/netty/
DNettyServer.java156 public void start(ServerListener serverListener) throws IOException { in start() argument
157 listener = checkNotNull(serverListener, "serverListener"); in start()