Method add

wal_e/pipebuf.py:71–73

(self, b)

        self.byteSz = 0

    def add(self, b):
        self._dq.append(b)
        self.byteSz += len(b)

    def get(self, n):
        assert n <= self.byteSz, 'caller responsibility to ensure enough bytes'