(fn, *args, **kwargs)
| 37 | |
| 38 | |
| 39 | def run_in_reactor_thread(fn, *args, **kwargs): |
| 40 | result = threads.blockingCallFromThread(TwistedObjects._REACTOR, fn, *args, **kwargs) |
| 41 | return result |
| 42 | |
| 43 | |
| 44 | def run_reactor(reactor): |
no outgoing calls
no test coverage detected