(iterable, close)
| 118 | |
| 119 | |
| 120 | def closing_iterator_wrapper(iterable, close): |
| 121 | try: |
| 122 | yield from iterable |
| 123 | finally: |
| 124 | request_finished.disconnect(close_old_connections) |
| 125 | close() # will fire request_finished |
| 126 | request_finished.connect(close_old_connections) |
| 127 | |
| 128 | |
| 129 | async def aclosing_iterator_wrapper(iterable, close): |
no test coverage detected