equal
deleted
inserted
replaced
73 def _callstream(self, cmd, **args): |
73 def _callstream(self, cmd, **args): |
74 return stringio(self._call(cmd, **args)) |
74 return stringio(self._call(cmd, **args)) |
75 |
75 |
76 @wireprotov1peer.batchable |
76 @wireprotov1peer.batchable |
77 def greet(self, name): |
77 def greet(self, name): |
78 f = wireprotov1peer.future() |
78 return {b'name': mangle(name)}, unmangle |
79 yield {b'name': mangle(name)}, f |
|
80 yield unmangle(f.value) |
|
81 |
79 |
82 |
80 |
83 class serverrepo(object): |
81 class serverrepo(object): |
84 def __init__(self, ui): |
82 def __init__(self, ui): |
85 self.ui = ui |
83 self.ui = ui |