def compress(self, message): self.compressor.compress(message) message = self.compressor.flush(zlib.Z_SYNC_FLUSH) assert message.endswith(b'\x00\x00\xff\xff') return message[:-4]