pub fn sse_body_stream( rx: Receiver<Bytes>, ) -> impl Stream<Item = Result<Bytes, Infallible>> + Send + 'static