--- a/mercurial/wireproto.py Fri May 11 18:41:04 2012 +0200
+++ b/mercurial/wireproto.py Sat May 12 15:54:54 2012 +0200
@@ -24,9 +24,9 @@
class batcher(object):
'''base class for batches of commands submittable in a single request
- All methods invoked on instances of this class are simply queued and return a
- a future for the result. Once you call submit(), all the queued calls are
- performed and the results set in their respective futures.
+ All methods invoked on instances of this class are simply queued and
+ return a a future for the result. Once you call submit(), all the queued
+ calls are performed and the results set in their respective futures.
'''
def __init__(self):
self.calls = []
@@ -51,7 +51,8 @@
class remotebatch(batcher):
'''batches the queued calls; uses as few roundtrips as possible'''
def __init__(self, remote):
- '''remote must support _submitbatch(encbatch) and _submitone(op, encargs)'''
+ '''remote must support _submitbatch(encbatch) and
+ _submitone(op, encargs)'''
batcher.__init__(self)
self.remote = remote
def submit(self):
@@ -97,14 +98,14 @@
encresref = future()
# Return encoded arguments and future:
yield encargs, encresref
- # Assuming the future to be filled with the result from the batched request
- # now. Decode it:
+ # Assuming the future to be filled with the result from the batched
+ # request now. Decode it:
yield decode(encresref.value)
- The decorator returns a function which wraps this coroutine as a plain method,
- but adds the original method as an attribute called "batchable", which is
- used by remotebatch to split the call into separate encoding and decoding
- phases.
+ The decorator returns a function which wraps this coroutine as a plain
+ method, but adds the original method as an attribute called "batchable",
+ which is used by remotebatch to split the call into separate encoding and
+ decoding phases.
'''
def plain(*args, **opts):
batchable = f(*args, **opts)