Comments
Patch
@@ -681,10 +681,11 @@ def _allowstream(ui):
def _walkstreamfiles(repo):
# this is it's own function so extensions can override it
return repo.store.walk()
+@wireprotocommand('stream_out')
def stream(repo, proto):
'''If the server supports streaming clone, it advertises the "stream"
capability with a value representing the version and flags of the repo
it is serving. Client checks to see if it understands the format.
@@ -794,8 +795,7 @@ def unbundle(repo, proto, heads):
finally:
fp.close()
os.unlink(tempname)
commands.update({
- 'stream_out': (stream, ''),
'unbundle': (unbundle, 'heads'),
})