comparison mercurial/changegroup.py @ 12044:bcc7139521b7

bundlerepo: remove duplication of bundle decompressors

12043:bef5effb3db0

    return generator(fh)

class unbundle10(object):
    def __init__(self, fh, alg):
        self._stream = util.chunkbuffer(decompressor(fh, alg))
    def read(self, l):
        return self._stream.read(l)

def readbundle(fh, fname):
    header = fh.read(6)

12044:bcc7139521b7

    return generator(fh)

class unbundle10(object):
    def __init__(self, fh, alg):
        self._stream = util.chunkbuffer(decompressor(fh, alg))
        self._type = alg
    def compressed(self):
        return self._type != 'UN'
    def read(self, l):
        return self._stream.read(l)

def readbundle(fh, fname):
    header = fh.read(6)