Searched refs:verifyMessageCountAndClose (Results 1 – 1 of 1) sorted by relevance
| /external/grpc-grpc-java/testing/src/main/java/io/grpc/internal/testing/ |
| D | AbstractTransportTest.java | 1257 int serverReceived = verifyMessageCountAndClose(serverStreamListener.messageQueue, 1); in flowControlPushBack()
1281 int clientReceived = verifyMessageCountAndClose(clientStreamListener.messageQueue, 1); in flowControlPushBack()
1286 clientReceived += verifyMessageCountAndClose(clientStreamListener.messageQueue, 3); in flowControlPushBack()
1287 serverReceived += verifyMessageCountAndClose(serverStreamListener.messageQueue, 3); in flowControlPushBack()
1293 verifyMessageCountAndClose(clientStreamListener.messageQueue, serverSent - clientReceived); in flowControlPushBack()
1295 verifyMessageCountAndClose(serverStreamListener.messageQueue, clientSent - serverReceived); in flowControlPushBack()
1310 clientReceived += verifyMessageCountAndClose(clientStreamListener.messageQueue, 4); in flowControlPushBack()
1311 serverReceived += verifyMessageCountAndClose(serverStreamListener.messageQueue, 4); in flowControlPushBack()
1316 clientReceived += verifyMessageCountAndClose(clientStreamListener.messageQueue, 1); in flowControlPushBack()
1317 serverReceived += verifyMessageCountAndClose(serverStreamListener.messageQueue, 1); in flowControlPushBack()
[all …]
|