Skip to content

Commit 7eb0f18

Browse files
committed
fix(http): Wake Payload when feeding error or eof
Signed-off-by: Thales Fragoso <thales.fragoso@axiros.com>
1 parent d9f74dc commit 7eb0f18

File tree

1 file changed

+3
-2
lines changed

1 file changed

+3
-2
lines changed

actix-http/src/h1/payload.rs

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -200,11 +200,13 @@ impl Inner {
200200
#[inline]
201201
fn set_error(&mut self, err: PayloadError) {
202202
self.err = Some(err);
203+
self.wake();
203204
}
204205

205206
#[inline]
206207
fn feed_eof(&mut self) {
207208
self.eof = true;
209+
self.wake();
208210
}
209211

210212
#[inline]
@@ -253,8 +255,7 @@ impl Inner {
253255

254256
#[cfg(test)]
255257
mod tests {
256-
use std::task::Poll;
257-
use std::time::Duration;
258+
use std::{task::Poll, time::Duration};
258259

259260
use actix_rt::time::timeout;
260261
use actix_utils::future::poll_fn;

0 commit comments

Comments
 (0)