| 1572 | assert drained == 1, drained |
| 1573 | |
| 1574 | def testDrainFlow(self): |
| 1575 | assert self.rcv.credit == 0 |
| 1576 | assert self.snd.credit == 0 |
| 1577 | self.rcv.drain(10) |
| 1578 | assert self.rcv.credit == 10 |
| 1579 | assert self.snd.credit == 0 |
| 1580 | self.pump() |
| 1581 | assert self.rcv.credit == 10 |
| 1582 | assert self.snd.credit == 10 |
| 1583 | self.snd.drained() |
| 1584 | assert self.rcv.credit == 10 |
| 1585 | assert self.snd.credit == 0 |
| 1586 | self.pump() |
| 1587 | assert self.rcv.credit == 0 |
| 1588 | assert self.snd.credit == 0 |
| 1589 | self.rcv.flow(10) |
| 1590 | assert self.rcv.credit == 10 |
| 1591 | assert self.snd.credit == 0 |
| 1592 | self.pump() |
| 1593 | assert self.rcv.credit == 10 |
| 1594 | assert self.snd.credit == 10 |
| 1595 | self.snd.drained() |
| 1596 | assert self.rcv.credit == 10 |
| 1597 | assert self.snd.credit == 10 |
| 1598 | self.pump() |
| 1599 | assert self.rcv.credit == 10 |
| 1600 | assert self.snd.credit == 10 |
| 1601 | drained = self.rcv.drained() |
| 1602 | assert drained == 10, drained |
| 1603 | |
| 1604 | def testNegative(self): |
| 1605 | assert self.snd.credit == 0 |