def __init__()

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

• 12 lines of code
• 1 McCabe index (conditional complexity)

    def __init__(self, stream: DefaultHttp2Stream, loop: asyncio.AbstractEventLoop, protocol):
        from dubbo.remoting.aio.http2.protocol import AbstractHttp2Protocol

        super().__init__(loop)

        self._stream = stream
        self._protocol: AbstractHttp2Protocol = protocol

        self._headers_put_event: asyncio.Event = asyncio.Event()
        self._headers_sent_event: asyncio.Event = asyncio.Event()
        self._headers: Optional[HeadersFrame] = None

        self._data_queue: asyncio.Queue[DataFrame] = asyncio.Queue()
        self._data_sent_event: asyncio.Event = asyncio.Event()

        self._trailers: Optional[HeadersFrame] = None

        # Start the controller
        self.start()