aboutsummaryrefslogtreecommitdiff
path: root/src/api/signature/streaming.rs
diff options
context:
space:
mode:
authorKokaKiwi <kokakiwi+git@kokakiwi.net>2022-02-18 17:05:19 +0100
committerGitea <gitea@fake.local>2022-03-23 10:22:36 +0100
commit98545a16dd9e469271fe480cc6f8d9991cd25444 (patch)
treeb78bf697fc5507e31f177ea2c04990bac7879d45 /src/api/signature/streaming.rs
parent822128e3c87b054eeab3696338dc688be3838e6f (diff)
downloadgarage-98545a16dd9e469271fe480cc6f8d9991cd25444.tar.gz
garage-98545a16dd9e469271fe480cc6f8d9991cd25444.zip
garage_api: Handle streaming payload early in request handling
Diffstat (limited to 'src/api/signature/streaming.rs')
-rw-r--r--src/api/signature/streaming.rs6
1 files changed, 3 insertions, 3 deletions
diff --git a/src/api/signature/streaming.rs b/src/api/signature/streaming.rs
index b2dc1591..b04e5c72 100644
--- a/src/api/signature/streaming.rs
+++ b/src/api/signature/streaming.rs
@@ -164,15 +164,15 @@ where
datetime: DateTime<Utc>,
scope: &str,
seed_signature: Hash,
- ) -> Result<Self, Error> {
- Ok(Self {
+ ) -> Self {
+ Self {
stream,
buf: bytes::BytesMut::new(),
datetime,
scope: scope.into(),
signing_hmac,
previous_signature: seed_signature,
- })
+ }
}
fn parse_next(input: &[u8]) -> nom::IResult<&[u8], SignedPayload, SignedPayloadStreamError> {