equal
deleted
inserted
replaced
258 b'unbundle', |
258 b'unbundle', |
259 } |
259 } |
260 legacycaps = moderncaps.union({b'changegroupsubset'}) |
260 legacycaps = moderncaps.union({b'changegroupsubset'}) |
261 |
261 |
262 |
262 |
263 class LocalCommandExecutor: |
263 class localcommandexecutor: # (repository.ipeercommandexecutor) |
264 def __init__(self, peer): |
264 def __init__(self, peer): |
265 self._peer = peer |
265 self._peer = peer |
266 self._sent = False |
266 self._sent = False |
267 self._closed = False |
267 self._closed = False |
268 |
268 |
301 def sendcommands(self): |
301 def sendcommands(self): |
302 self._sent = True |
302 self._sent = True |
303 |
303 |
304 def close(self): |
304 def close(self): |
305 self._closed = True |
305 self._closed = True |
306 |
|
307 |
|
308 localcommandexecutor = interfaceutil.implementer( |
|
309 repository.ipeercommandexecutor |
|
310 )(LocalCommandExecutor) |
|
311 |
|
312 if typing.TYPE_CHECKING: |
|
313 # Help pytype by hiding the interface stuff that confuses it. |
|
314 localcommandexecutor = LocalCommandExecutor |
|
315 |
306 |
316 |
307 |
317 class LocalPeer(repository.peer): |
308 class LocalPeer(repository.peer): |
318 '''peer for a local repo; reflects only the most recent API''' |
309 '''peer for a local repo; reflects only the most recent API''' |
319 |
310 |