(green_thread, *args, **kwargs)
| 96 | |
| 97 | |
| 98 | def wait(green_thread, *args, **kwargs): |
| 99 | if CONCURRENCY_LIBRARY == "eventlet": |
| 100 | return green_thread.wait(*args, **kwargs) |
| 101 | elif CONCURRENCY_LIBRARY == "gevent": |
| 102 | return green_thread.join(*args, **kwargs) |
| 103 | else: |
| 104 | raise ValueError("Unsupported concurrency library") |
| 105 | |
| 106 | |
| 107 | def cancel(green_thread, *args, **kwargs): |