clia-reqwest-ntex-stream

连接 Reqwest 和 ntex 两个系统的流。

PayloadStream 示例

async fn handle(
    body: ntex::web::types::Payload,
) {
    let mut builder = client.get(url);
    // This stream is not for send between threads, otherwise it's unsafe.
    builder = builder.body(reqwest::Body::wrap_stream(reqwest_ntex_stream::PayloadStream {
        payload: body,
    }));
    builder.send().await;
}

ResponseStream 示例

let res = builder.send().await;
let stream = res.bytes_stream();
let mut resp = HttpResponse::build(res.status());
// This method will use chunked Transfer-Encoding, otherwise use ntex::http::body::SizedStream
return Ok(resp.streaming(reqwest_ntex_stream::ResponseStream{ stream: stream }));