Method receive_data

gunicorn/http2/stream.py:129–159

Process received DATA frame with streaming support. Args: data: Bytes received end_stream: True if END_STREAM flag is set Raises: HTTP2StreamError: If data received in invalid state

(self, data, end_stream=False)

            self.request_complete = True

    def receive_data(self, data, end_stream=False):
        """Process received DATA frame with streaming support.

        Args:
            data: Bytes received
            end_stream: True if END_STREAM flag is set

        Raises:
            HTTP2StreamError: If data received in invalid state
        """
        if not self.can_receive:
            raise HTTP2StreamError(
                self.stream_id,
                f"Cannot receive data in state {self.state.name}"
            )

        # Add to chunks queue for streaming reads
        if data:
            self._body_chunks.append(data)
            if self._body_event:
                self._body_event.set()

        # Also write to legacy BytesIO for compatibility
        self.request_body.write(data)

        if end_stream:
            self._half_close_remote()
            self.request_complete = True
            self._body_complete = True
            if self._body_event:
                self._body_event.set()

    def receive_trailers(self, trailers):
        """Process received trailing headers.