Decompress the given data.
(
self, data: Buffer, max_length: int = ZLIB_MAX_LENGTH_UNLIMITED
)
| 172 | """Decompress the given data.""" |
| 173 | |
| 174 | async def decompress( |
| 175 | self, data: Buffer, max_length: int = ZLIB_MAX_LENGTH_UNLIMITED |
| 176 | ) -> bytes: |
| 177 | """Decompress the given data.""" |
| 178 | if ( |
| 179 | self._max_sync_chunk_size is not None |
| 180 | and len(data) > self._max_sync_chunk_size |
| 181 | ): |
| 182 | return await asyncio.get_event_loop().run_in_executor( |
| 183 | self._executor, self.decompress_sync, data, max_length |
| 184 | ) |
| 185 | return self.decompress_sync(data, max_length) |
| 186 | |
| 187 | @property |
| 188 | @abstractmethod |
nothing calls this directly
no test coverage detected