from io import TextIOWrapper, BytesIO """ Compression utilities for various formats. """ def zstd_decompress(data: bytes | BytesIO) -> TextIOWrapper: """Decompress Zstandard compressed data in a memory efficient manner (using streams). Args: data (bytes): The compressed data. Returns: str: The decompressed data as a stream. """ import zstandard decompressor = zstandard.ZstdDecompressor() return TextIOWrapper(decompressor.stream_reader(data), encoding="utf-8")