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)
| 105 | return True |
| 106 | |
| 107 | def pump(transport1, transport2, buffer_size=1024): |
| 108 | """ Transfer all pending bytes between two Proton engines |
| 109 | by repeatedly calling peek/pop and push. |
| 110 | Asserts that each engine accepts some bytes every time |
| 111 | (unless it's already closed). |
| 112 | """ |
| 113 | while (pump_uni(transport1, transport2, buffer_size) or |
| 114 | pump_uni(transport2, transport1, buffer_size)): |
| 115 | pass |
| 116 | |
| 117 | def findfileinpath(filename, searchpath): |
| 118 | """Find filename in the searchpath |