Skip to content

Commit 833bbd0

Browse files
committed
feat: moved DecompressTrait impl &mut OneOne to OneOne
1 parent 10f2f56 commit 833bbd0

File tree

7 files changed

+11
-11
lines changed

7 files changed

+11
-11
lines changed

Cargo.lock

Lines changed: 2 additions & 2 deletions
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

src/convert/chunked.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -22,7 +22,7 @@ use header_plz::{
2222
* b. add trailer to header_map.
2323
*/
2424

25-
pub fn chunked_to_raw<T>(mut one: &mut OneOne<T>, buf: &mut BytesMut)
25+
pub fn chunked_to_raw<T>(one: &mut OneOne<T>, buf: &mut BytesMut)
2626
where
2727
T: InfoLine,
2828
MessageHead<T>: ParseBodyHeaders,

src/convert/mod.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -32,7 +32,7 @@ use crate::oneone::OneOne;
3232
*/
3333

3434
pub fn convert_body<T>(
35-
mut one: &mut OneOne<T>,
35+
one: &mut OneOne<T>,
3636
extra_body: Option<BytesMut>,
3737
buf: &mut BytesMut,
3838
) -> Result<(), std::io::Error>

src/error.rs

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -60,8 +60,8 @@ where
6060
match value {
6161
HttpStateError::ContentLengthPartial(mut oneone, buf) => {
6262
let len = buf.len();
63-
(&mut oneone).set_body(Body::Raw(buf));
64-
update_content_length(&mut (&mut oneone), len);
63+
oneone.set_body(Body::Raw(buf));
64+
update_content_length(&mut oneone, len);
6565
Ok(oneone)
6666
}
6767
_ => Err(value),

src/oneone/impl_decompress.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -4,7 +4,7 @@ use header_plz::{HeaderMap, InfoLine, body_headers::BodyHeader};
44

55
use crate::oneone::OneOne;
66

7-
impl<T> DecompressTrait for &mut OneOne<T>
7+
impl<T> DecompressTrait for OneOne<T>
88
where
99
T: InfoLine,
1010
{

src/oneone/impl_try_from_bytes.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -45,7 +45,7 @@ where
4545
OneOne::try_from_message_head_buf(message_head)?;
4646
if !buf.is_empty() {
4747
let len = buf.len().to_string();
48-
(&mut one).set_body(Body::Raw(buf));
48+
one.set_body(Body::Raw(buf));
4949
if !one.update_header_value_on_key(CONTENT_LENGTH, len.as_str()) {
5050
one.add_header(CONTENT_LENGTH, &len);
5151
}

src/state.rs

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -79,7 +79,7 @@ where
7979
}
8080
}
8181
TransferType::Chunked => {
82-
(&mut one).set_body(Body::Chunked(Vec::new()));
82+
one.set_body(Body::Chunked(Vec::new()));
8383
Self::ReadBodyChunked(one, ChunkReaderState::ReadSize)
8484
}
8585
TransferType::Close => Self::ReadBodyClose(one),
@@ -124,7 +124,7 @@ where
124124
Event::Read(ref mut buf) | Event::End(ref mut buf) => {
125125
match read_content_length(buf, &mut size) {
126126
true => {
127-
(&mut oneone).set_body(Body::Raw(
127+
oneone.set_body(Body::Raw(
128128
buf.split_at_current_pos(),
129129
));
130130
if buf.len() > 0 {
@@ -215,7 +215,7 @@ where
215215
Ok(Self::ReadBodyClose(oneone))
216216
}
217217
(State::ReadBodyClose(mut oneone), Event::End(buf)) => {
218-
(&mut oneone).set_body(Body::Raw(buf.into_inner()));
218+
oneone.set_body(Body::Raw(buf.into_inner()));
219219
Ok(State::End(oneone))
220220
}
221221
(State::End(oneone), event) => {

0 commit comments

Comments
 (0)