async def METHOD_NAME() -> dict:
    nonlocal request_complete
    if request_complete:
        await response_complete.wait()
        return {"type": "http.disconnect"}
    try:
        body = await request_body_chunks.__anext__()
    except StopAsyncIteration:
        request_complete = True
        return {"type": "http.request", "body": b"", "more_body": False}
    return {"type": "http.request", "body": body, "more_body": True}