saluki_core/data_model/payload/http/
mod.rs

1use http::Request;
2use saluki_common::buf::FrozenChunkedBytesBuffer;
3
4use super::PayloadMetadata;
5
6/// An HTTP payload.
7#[derive(Clone)]
8pub struct HttpPayload {
9    metadata: PayloadMetadata,
10    req: Request<FrozenChunkedBytesBuffer>,
11}
12
13impl HttpPayload {
14    /// Creates a new `HttpPayload` from the given request.
15    pub fn new(metadata: PayloadMetadata, req: Request<FrozenChunkedBytesBuffer>) -> Self {
16        HttpPayload { metadata, req }
17    }
18
19    /// Consumes the HTTP payload and returns the individual parts.
20    pub fn into_parts(self) -> (PayloadMetadata, Request<FrozenChunkedBytesBuffer>) {
21        (self.metadata, self.req)
22    }
23}

saluki_core/data_model/payload/http/mod.rs

saluki_core/data_model/payload/http/
mod.rs