We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 9b76cb3 commit 73074e0Copy full SHA for 73074e0
expression/core/aiotools.py
@@ -46,13 +46,16 @@ def from_continuations(callback: Callbacks[_TSource]) -> Awaitable[_TSource]:
46
future: "Future[_TSource]" = asyncio.Future()
47
48
def done(value: _TSource) -> None:
49
- future.set_result(value)
+ if not future.done():
50
+ future.set_result(value)
51
52
def error(err: Exception) -> None:
- future.set_exception(err)
53
54
+ future.set_exception(err)
55
56
def cancel(_: OperationCanceledError) -> None:
- future.cancel()
57
58
+ future.cancel()
59
60
callback(done, error, cancel)
61
return future
0 commit comments