Compression

gzip

rxsci.compression.z.compress()

Compresses an Observable of bytes with gzip-compression

The incoming elements are compressed in streaming mode until the observable completed.

The source must be an Observable.

rxsci.compression.z.decompress()

Decompresses an Observable of bytes with gzip-compression

The incoming elements are decompressed in streaming mode until the observable completed.

The source must be an Observable.

zstd

rxsci.compression.zstd.compress()

Compresses an Observable of bytes with zstd-compression

The incoming elements are compressed in streaming mode until the observable completed.

The source must be an Observable.

rxsci.compression.zstd.decompress()

Decompresses an Observable of bytes with zstd-compression

The incoming elements are decompressed in streaming mode until the observable completed.

The source must be an Observable.