berkus
/
actix-web
mirror of https://github.com/fafhrd91/actix-web
1
0
Fork 0
Code Issues Releases Wiki Activity

fix method calls

This commit is contained in:
Rob Ede 2022-01-31 15:47:40 +00:00
parent 6cf83e5c24
commit faac73de63
No known key found for this signature in database
GPG Key ID: 97C636207D3EF933
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
awc/src/client/h1proto.rs
View File

@ -70,7 +70,7 @@ where
let is_expect = if head.as_ref().headers.contains_key(EXPECT) { let is_expect = if head.as_ref().headers.contains_key(EXPECT) {
match body.size() { match body.size() {
BodySize::None | BodySize::Sized(0) => { BodySize::None | BodySize::Sized(0) => {
let keep_alive = framed.codec_ref().keepalive(); let keep_alive = framed.codec_ref().keep_alive();
framed.io_mut().on_release(keep_alive); framed.io_mut().on_release(keep_alive);
// TODO: use a new variant or a new type better describing error violate // TODO: use a new variant or a new type better describing error violate
@ -119,7 +119,7 @@ where
match pin_framed.codec_ref().message_type() { match pin_framed.codec_ref().message_type() {
h1::MessageType::None => { h1::MessageType::None => {
let keep_alive = pin_framed.codec_ref().keepalive(); let keep_alive = pin_framed.codec_ref().keep_alive();
pin_framed.io_mut().on_release(keep_alive); pin_framed.io_mut().on_release(keep_alive);
Ok((head, Payload::None)) Ok((head, Payload::None))
@ -223,7 +223,7 @@ impl<Io: ConnectionIo> Stream for PlStream<Io> {
match ready!(this.framed.as_mut().next_item(cx)?) { match ready!(this.framed.as_mut().next_item(cx)?) {
Some(Some(chunk)) => Poll::Ready(Some(Ok(chunk))), Some(Some(chunk)) => Poll::Ready(Some(Ok(chunk))),
Some(None) => { Some(None) => {
let keep_alive = this.framed.codec_ref().keepalive(); let keep_alive = this.framed.codec_ref().keep_alive();
this.framed.io_mut().on_release(keep_alive); this.framed.io_mut().on_release(keep_alive);
Poll::Ready(None) Poll::Ready(None)
} }