Function compress_stream 

pub fn compress_stream(
    rx: Receiver<Vec<u8>>,
) -> BoxBody<Bytes, Box<dyn Error + Send + Sync + 'static>>

Wrap a streaming response body with brotli compression.