🐛 fix streaming_response bug

ajndkr · Nov 16, 2023 · 4d09b73 · 4d09b73
1 parent e8d786f
commit 4d09b73
Showing 1 changed file with 2 additions and 4 deletions.
diff --git a/lanarky/responses/streaming.py b/lanarky/responses/streaming.py
@@ -70,13 +70,11 @@ async def stream_response(self, send: Send) -> None:
                 {
                     "type": "http.response.body",
                     "body": ensure_bytes(chunk, None),
-                    "more_body": False,
+                    "more_body": True,
                 }
             )
 
-        async with self._send_lock:
-            self.active = False
-            await send({"type": "http.response.body", "body": b"", "more_body": False})
+        await send({"type": "http.response.body", "body": b"", "more_body": False})
 
     @staticmethod
     def _create_chain_executor(