equal
deleted
inserted
replaced
47 chunk = cg.read(4096) |
47 chunk = cg.read(4096) |
48 if not chunk: |
48 if not chunk: |
49 break |
49 break |
50 self.req.write(z.compress(chunk)) |
50 self.req.write(z.compress(chunk)) |
51 self.req.write(z.flush()) |
51 self.req.write(z.flush()) |
52 |
52 def sendstream(self, source): |
|
53 self.req.respond(HTTP_OK, HGTYPE) |
|
54 for chunk in source: |
|
55 self.req.write(chunk) |
53 def respond(self, s): |
56 def respond(self, s): |
54 self.req.respond(HTTP_OK, HGTYPE, length=len(s)) |
57 self.req.respond(HTTP_OK, HGTYPE, length=len(s)) |
55 self.response = s |
58 self.response = s |
56 |
59 |
57 def callproto(repo, req, cmd): |
60 def callproto(repo, req, cmd): |