Transfer all pending bytes between two Proton engines by repeatedly calling peek/pop and push. Asserts that each engine accepts some bytes every time (unless it's already closed).
(transport1, transport2, buffer_size=1024)
| 83 | |
| 84 | |
| 85 | def pump(transport1, transport2, buffer_size=1024): |
| 86 | """ Transfer all pending bytes between two Proton engines |
| 87 | by repeatedly calling peek/pop and push. |
| 88 | Asserts that each engine accepts some bytes every time |
| 89 | (unless it's already closed). |
| 90 | """ |
| 91 | while (pump_uni(transport1, transport2, buffer_size) or pump_uni(transport2, transport1, buffer_size)): |
| 92 | pass |
| 93 | |
| 94 | |
| 95 | def findfileinpath(filename, searchpath): |