equal
deleted
inserted
replaced
857 part = seekableunbundlepart(self.ui, headerblock, self._fp) |
857 part = seekableunbundlepart(self.ui, headerblock, self._fp) |
858 yield part |
858 yield part |
859 # Ensure part is fully consumed so we can start reading the next |
859 # Ensure part is fully consumed so we can start reading the next |
860 # part. |
860 # part. |
861 part.consume() |
861 part.consume() |
862 # But then seek back to the beginning so the code consuming this |
862 |
863 # generator has a part that starts at 0. |
|
864 part.seek(0, os.SEEK_SET) |
|
865 headerblock = self._readpartheader() |
863 headerblock = self._readpartheader() |
866 indebug(self.ui, 'end of bundle2 stream') |
864 indebug(self.ui, 'end of bundle2 stream') |
867 |
865 |
868 def _readpartheader(self): |
866 def _readpartheader(self): |
869 """reads a part header size and return the bytes blob |
867 """reads a part header size and return the bytes blob |