diff mercurial/sshserver.py @ 11623:31d0a6d50ee2

protocol: extract compression from streaming mechanics

--- a/mercurial/sshserver.py	Fri Jul 16 18:18:35 2010 +0200
+++ b/mercurial/sshserver.py	Fri Jul 16 22:20:10 2010 +0200
@@ -59,18 +59,16 @@
     def redirect(self):
         pass
 
-    def sendresponse(self, v):
-        self.fout.write("%d\n" % len(v))
-        self.fout.write(v)
-        self.fout.flush()
-
-    def sendchangegroup(self, changegroup):
+    def groupchunks(self, changegroup):
         while True:
             d = changegroup.read(4096)
             if not d:
                 break
-            self.fout.write(d)
+            yield d
 
+    def sendresponse(self, v):
+        self.fout.write("%d\n" % len(v))
+        self.fout.write(v)
         self.fout.flush()
 
     def sendstream(self, source):