|
16 | 16 | import gc
|
17 | 17 | import hashlib
|
18 | 18 | import hmac
|
19 |
| -import inspect |
20 | 19 | import json
|
21 | 20 | import logging
|
22 | 21 | import secrets
|
@@ -519,33 +518,23 @@ def pump(self, by=0.0):
|
519 | 518 | self.reactor.pump([by] * 100)
|
520 | 519 |
|
521 | 520 | def get_success(self, d, by=0.0):
|
522 |
| - if inspect.isawaitable(d): |
523 |
| - d = ensureDeferred(d) |
524 |
| - if not isinstance(d, Deferred): |
525 |
| - return d |
| 521 | + deferred: Deferred[TV] = ensureDeferred(d) |
526 | 522 | self.pump(by=by)
|
527 |
| - return self.successResultOf(d) |
| 523 | + return self.successResultOf(deferred) |
528 | 524 |
|
529 | 525 | def get_failure(self, d, exc):
|
530 | 526 | """
|
531 | 527 | Run a Deferred and get a Failure from it. The failure must be of the type `exc`.
|
532 | 528 | """
|
533 |
| - if inspect.isawaitable(d): |
534 |
| - d = ensureDeferred(d) |
535 |
| - if not isinstance(d, Deferred): |
536 |
| - return d |
| 529 | + deferred: Deferred[Any] = ensureDeferred(d) |
537 | 530 | self.pump()
|
538 |
| - return self.failureResultOf(d, exc) |
| 531 | + return self.failureResultOf(deferred, exc) |
539 | 532 |
|
540 | 533 | def get_success_or_raise(self, d, by=0.0):
|
541 | 534 | """Drive deferred to completion and return result or raise exception
|
542 | 535 | on failure.
|
543 | 536 | """
|
544 |
| - |
545 |
| - if inspect.isawaitable(d): |
546 |
| - deferred = ensureDeferred(d) |
547 |
| - if not isinstance(deferred, Deferred): |
548 |
| - return d |
| 537 | + deferred: Deferred[TV] = ensureDeferred(d) |
549 | 538 |
|
550 | 539 | results: list = []
|
551 | 540 | deferred.addBoth(results.append)
|
|
0 commit comments