equal
deleted
inserted
replaced
9 |
9 |
10 from mercurial import ( |
10 from mercurial import ( |
11 error, |
11 error, |
12 peer, |
12 peer, |
13 util, |
13 util, |
14 wireproto, |
14 wireprotov1peer, |
15 ) |
15 ) |
16 |
16 |
17 # equivalent of repo.repository |
17 # equivalent of repo.repository |
18 class thing(object): |
18 class thing(object): |
19 def hello(self): |
19 def hello(self): |
175 res = self._submitone('batch', [('cmds', req,)]) |
175 res = self._submitone('batch', [('cmds', req,)]) |
176 for r in res.split(';'): |
176 for r in res.split(';'): |
177 yield r |
177 yield r |
178 |
178 |
179 def batchiter(self): |
179 def batchiter(self): |
180 return wireproto.remoteiterbatcher(self) |
180 return wireprotov1peer.remoteiterbatcher(self) |
181 |
181 |
182 @peer.batchable |
182 @peer.batchable |
183 def foo(self, one, two=None): |
183 def foo(self, one, two=None): |
184 encargs = [('one', mangle(one),), ('two', mangle(two),)] |
184 encargs = [('one', mangle(one),), ('two', mangle(two),)] |
185 encresref = peer.future() |
185 encresref = peer.future() |