compressionStream property

Stream<CompressedLogBatch> get compressionStream

Stream of compressed log batches

Implementation

Stream<CompressedLogBatch> get compressionStream =>
    _compressionStreamController.stream;