objectstore-client 0.2.6

Client SDK for Objectstore, the Sentry object storage platform
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25

//! Helpers for consuming HTTP responses.

use reqwest::Response;

/// Extension trait with methods to consume response bodies, to ensure that connections are
/// released cleanly.
pub(crate) trait ResponseExt {
    async fn drain_body(self);
    async fn error_for_status_and_drain(self) -> reqwest::Result<Response>;
}

impl ResponseExt for Response {
    async fn drain_body(mut self) {
        while let Ok(Some(_)) = self.chunk().await {}
    }

    async fn error_for_status_and_drain(self) -> reqwest::Result<Response> {
        let Err(error) = self.error_for_status_ref() else {
            return Ok(self);
        };

        self.drain_body().await;
        Err(error)
    }
}