Method read_body_chunk

gunicorn/http2/stream.py:301–328

Read next body chunk asynchronously for streaming. Returns: bytes: Next chunk of body data, or None if body is complete.

(self)

        return self.request_body.getvalue()

    async def read_body_chunk(self):
        """Read next body chunk asynchronously for streaming.

        Returns:
            bytes: Next chunk of body data, or None if body is complete.
        """
        import asyncio

        # Initialize event lazily (avoids event loop issues at construction)
        if self._body_event is None:
            self._body_event = asyncio.Event()
            # If data already arrived before event existed, set it now
            # This prevents race where DATA frames arrive before first read
            if self._body_chunks or self._body_complete:
                self._body_event.set()

        while True:
            # Return chunk if available
            if self._body_chunks:
                return self._body_chunks.pop(0)

            # No more data expected
            if self._body_complete:
                return None

            # Wait for more data
            self._body_event.clear()
            await self._body_event.wait()

    def get_pseudo_headers(self):
        """Extract HTTP/2 pseudo-headers from request headers.