def handle_frame()

in src/dubbo/remoting/aio/http2/stream_handler.py [0:0]

• 8 lines of code
• 6 McCabe index (conditional complexity)

    def handle_frame(self, frame: UserActionFrames) -> None:
        """
        Handle the HTTP/2 frame.
        :param frame: The HTTP/2 frame.
        :type frame: UserActionFrames
        """
        stream = self._streams.get(frame.stream_id)
        if stream:
            # It must be ensured that the event loop is not blocked,
            # and if there is a blocking operation, the executor must be used.
            stream.receive_frame(frame)

            if frame.end_stream and stream.local_closed:
                self.remove_stream(frame.stream_id)
        else:
            _LOGGER.warning("Stream %s not found. Ignoring frame %s", frame.stream_id, frame)