Searched refs:getPendingStreamsCount (Results 1 – 2 of 2) sorted by relevance
| /external/grpc-grpc-java/core/src/test/java/io/grpc/internal/ |
| D | DelayedClientTransportTest.java | 126 assertEquals(1, delayedTransport.getPendingStreamsCount()); in streamStartThenAssignTransport()
131 assertEquals(0, delayedTransport.getPendingStreamsCount()); in streamStartThenAssignTransport()
144 assertEquals(1, delayedTransport.getPendingStreamsCount()); in newStreamThenAssignTransportThenShutdown()
147 assertEquals(0, delayedTransport.getPendingStreamsCount()); in newStreamThenAssignTransportThenShutdown()
171 assertEquals(0, delayedTransport.getPendingStreamsCount()); in assignTransportThenShutdownThenNewStream()
183 assertEquals(0, delayedTransport.getPendingStreamsCount()); in assignTransportThenShutdownNowThenNewStream()
191 assertEquals(1, delayedTransport.getPendingStreamsCount()); in cancelStreamWithoutSetTransport()
193 assertEquals(0, delayedTransport.getPendingStreamsCount()); in cancelStreamWithoutSetTransport()
201 assertEquals(1, delayedTransport.getPendingStreamsCount()); in startThenCancelStreamWithoutSetTransport()
203 assertEquals(0, delayedTransport.getPendingStreamsCount()); in startThenCancelStreamWithoutSetTransport()
[all …]
|
| /external/grpc-grpc-java/core/src/main/java/io/grpc/internal/ |
| D | DelayedClientTransport.java | 182 if (getPendingStreamsCount() == 1) { in createPendingStream()
260 final int getPendingStreamsCount() { in getPendingStreamsCount() method in DelayedClientTransport
|