equal
deleted
inserted
replaced
74 self.fout.write(v) |
74 self.fout.write(v) |
75 self.fout.flush() |
75 self.fout.flush() |
76 |
76 |
77 def sendstream(self, source): |
77 def sendstream(self, source): |
78 write = self.fout.write |
78 write = self.fout.write |
79 |
79 for chunk in source.gen: |
80 if source.reader: |
|
81 gen = iter(lambda: source.reader.read(4096), '') |
|
82 else: |
|
83 gen = source.gen |
|
84 |
|
85 for chunk in gen: |
|
86 write(chunk) |
80 write(chunk) |
87 self.fout.flush() |
81 self.fout.flush() |
88 |
82 |
89 def sendpushresponse(self, rsp): |
83 def sendpushresponse(self, rsp): |
90 self.sendresponse('') |
84 self.sendresponse('') |