--- a/mercurial/httppeer.py Wed Mar 02 10:23:53 2022 -0500
+++ b/mercurial/httppeer.py Wed Mar 02 10:24:49 2022 -0500
@@ -14,6 +14,7 @@
import socket
import struct
+from concurrent import futures
from .i18n import _
from .pycompat import getattr
from . import (
@@ -538,12 +539,12 @@
raise exception
-class queuedcommandfuture(pycompat.futures.Future):
+class queuedcommandfuture(futures.Future):
"""Wraps result() on command futures to trigger submission on call."""
def result(self, timeout=None):
if self.done():
- return pycompat.futures.Future.result(self, timeout)
+ return futures.Future.result(self, timeout)
self._peerexecutor.sendcommands()