Searched refs:clientListener (Results 1 – 3 of 3) sorted by relevance
| /external/okhttp/okhttp-ws-tests/src/test/java/com/squareup/okhttp/internal/ws/ |
| D | RealWebSocketTest.java | 56 private final WebSocketRecorder clientListener = new WebSocketRecorder(); field in RealWebSocketTest
69 clientExecutor, clientListener, url) { in setUp()
93 clientListener.assertExhausted(); in tearDown()
174 clientListener.assertPong(new Buffer().writeUtf8("Pong?")); in streamingMessageCanInterleavePing()
181 clientListener.assertPong(new Buffer().writeUtf8("Hello!")); in pingWritesPong()
195 clientListener.assertClose(1000, "Hello!"); in close()
272 clientListener.assertClose(1000, "Hello!"); in serverCloseThenWritingPingThrows()
285 clientListener.assertClose(1000, "Hello!"); in serverCloseThenWritingMessageThrows()
298 clientListener.assertClose(1000, "Hello!"); in serverCloseThenWritingCloseThrows()
320 clientListener.assertClose(1000, "Hello!"); in serverCloseWhileWritingThrows()
[all …]
|
| /external/grpc-grpc-java/cronet/src/test/java/io/grpc/cronet/ |
| D | CronetClientStreamTest.java | 74 @Mock private ClientStreamListener clientListener; field in CronetClientStreamTest
128 clientStream.start(clientListener); in setUp()
245 verify(clientListener).headersRead(metadataCaptor.capture()); in read()
260 verify(clientListener, times(0)).messagesAvailable(isA(MessageProducer.class)); in read()
264 verify(clientListener, times(1)).messagesAvailable(isA(MessageProducer.class)); in read()
270 verify(clientListener, times(1)).messagesAvailable(isA(MessageProducer.class)); in read()
310 verify(clientListener, times(1)).messagesAvailable(isA(MessageProducer.class)); in streamSucceeded()
326 verify(clientListener) in streamSucceeded()
370 verify(clientListener) in streamSucceededWithGrpcError()
396 verify(clientListener) in streamFailed()
[all …]
|
| /external/grpc-grpc-java/testing/src/main/java/io/grpc/internal/testing/ |
| D | AbstractTransportTest.java | 1407 ClientStreamListener clientListener = mock(ClientStreamListener.class); in interactionsAfterClientStreamCancelAreNoops() local
1408 clientStream.start(clientListener); in interactionsAfterClientStreamCancelAreNoops()
|