equal
deleted
inserted
replaced
837 yield _pack(_fstreamparamsize, paramssize) |
837 yield _pack(_fstreamparamsize, paramssize) |
838 if paramssize: |
838 if paramssize: |
839 params = self._readexact(paramssize) |
839 params = self._readexact(paramssize) |
840 self._processallparams(params) |
840 self._processallparams(params) |
841 yield params |
841 yield params |
842 assert self._compengine.bundletype == 'UN' |
842 assert self._compengine.bundletype()[1] == 'UN' |
843 # From there, payload might need to be decompressed |
843 # From there, payload might need to be decompressed |
844 self._fp = self._compengine.decompressorreader(self._fp) |
844 self._fp = self._compengine.decompressorreader(self._fp) |
845 emptycount = 0 |
845 emptycount = 0 |
846 while emptycount < 2: |
846 while emptycount < 2: |
847 # so we can brainlessly loop |
847 # so we can brainlessly loop |