compress_message(self):         if self._is_server:             if self._decompressor is None or self.client_no_context_takeover:                 self._decompressor = snappy.StreamDecompressor()      