diff --git a/src/context.rs b/src/context.rs index 02eda8d5..aa6f4c49 100644 --- a/src/context.rs +++ b/src/context.rs @@ -164,6 +164,7 @@ impl HttpContext where A: Actor { self.stream = Some(SmallVec::new()); } self.stream.as_mut().map(|s| s.push(frame)); + self.inner.modify(); } /// Handle of the running future diff --git a/src/ws/context.rs b/src/ws/context.rs index 8720b461..56320c89 100644 --- a/src/ws/context.rs +++ b/src/ws/context.rs @@ -112,6 +112,7 @@ impl WebsocketContext where A: Actor { } let stream = self.stream.as_mut().unwrap(); stream.push(ContextFrame::Chunk(Some(data))); + self.inner.modify(); } else { warn!("Trying to write to disconnected response"); } @@ -179,6 +180,7 @@ impl WebsocketContext where A: Actor { self.stream = Some(SmallVec::new()); } self.stream.as_mut().map(|s| s.push(frame)); + self.inner.modify(); } /// Handle of the running future