(self, fn)
| 261 | return conn |
| 262 | |
| 263 | def _safe(self, fn): |
| 264 | try: |
| 265 | fn() |
| 266 | except Exception as e: |
| 267 | warnings.warn("ReconnectFixture couldn't close connection: %s" % e) |
| 268 | |
| 269 | def shutdown(self, stop=False): |
| 270 | # TODO: this doesn't cover all cases |