(iterable, close)
| 127 | |
| 128 | |
| 129 | async def aclosing_iterator_wrapper(iterable, close): |
| 130 | try: |
| 131 | async for chunk in iterable: |
| 132 | yield chunk |
| 133 | finally: |
| 134 | request_finished.disconnect(close_old_connections) |
| 135 | close() # will fire request_finished |
| 136 | request_finished.connect(close_old_connections) |
| 137 | |
| 138 | |
| 139 | def conditional_content_removal(request, response): |
no test coverage detected