如何在 actix_web/rust 的 http 响应中流式传输非静态字节？

如何解决如何在 actix_web/rust 的 http 响应中流式传输非静态字节？

我正在尝试生成一个图像，然后在来自 actix_web 的响应中发送它，我实现了一个 Trace 特征，在该特征中我尝试将图像字节传递给 actix_web::web::Bytes，但我的尝试无法编译，因为我生成的图像数据/字节不是静态的。

示例代码如下：

pub struct Image {
  pub index: usize,pub bytes_in_a_chunk: usize,pub raw: Vec<u8>,}

impl futures::stream::Stream for Image {
    type Item = Result<actix_web::web::Bytes,actix_web::Error>;

    fn poll_next(self: Pin<&mut Self>,_cx: &mut Context<'_>) -> Poll<Option<Self::Item>> {
        let length = self.raw.len();
        let bytes = self.raw.clone();
        let beg = self.index;
        let mut end = self.index + self.bytes;
        if end >= length {
            end = end - length;
        }
        let data = &bytes[beg..end];
        self.index += self.bytes_in_a_chunk;
        if data.len() <= 0 {
            Poll::Ready(None)
        } else {
            Poll::Ready(Some(Ok(actix_web::web::Bytes::from(data))))
        }
    }
}

pub async fn get_image() -> HttpResponse {
    let image: Image = generate_image();
    HttpResponse::PartialContent()
      .content_type(PNG_CONTENT_TYPE)
      .streaming(image);
}

有没有办法在响应中流式传输动态生成的字节？我认为一定有办法，但我很难找到不涉及发送静态字符串的示例或文档。

感谢您的帮助！干杯！

解决方法

您确定需要流吗？流基本上是一个异步迭代器，但如果您的内存中已经有完整的图像，则不需要。

您可以使用 Body::from_slice 复制字节：

pub async fn get_image() -> HttpResponse {
    let image: Image = generate_image();
    HttpResponse::Ok()
      .content_type("image/png")
      .body(Body::from_slice(&image.raw))
}

或者直接转让字节的所有权：

pub async fn get_image() -> HttpResponse {
    let Image { raw,.. } = generate_image();
    HttpResponse::Ok()
      .content_type("image/png")
      .body(raw)
}