| 1527 | self._testBufferingOnClose("connection", "connection") |
| 1528 | |
| 1529 | def testFullDrain(self): |
| 1530 | assert self.rcv.credit == 0 |
| 1531 | assert self.snd.credit == 0 |
| 1532 | self.rcv.drain(10) |
| 1533 | assert self.rcv.draining() |
| 1534 | assert self.rcv.credit == 10 |
| 1535 | assert self.snd.credit == 0 |
| 1536 | self.pump() |
| 1537 | assert self.rcv.credit == 10 |
| 1538 | assert self.snd.credit == 10 |
| 1539 | assert self.rcv.draining() |
| 1540 | self.snd.drained() |
| 1541 | assert self.rcv.credit == 10 |
| 1542 | assert self.snd.credit == 0 |
| 1543 | assert self.rcv.draining() |
| 1544 | self.pump() |
| 1545 | assert self.rcv.credit == 0 |
| 1546 | assert self.snd.credit == 0 |
| 1547 | assert not self.rcv.draining() |
| 1548 | drained = self.rcv.drained() |
| 1549 | assert drained == 10, drained |
| 1550 | |
| 1551 | def testPartialDrain(self): |
| 1552 | self.rcv.drain(2) |