def METHOD_NAME(self) -> Receive:
    body = None
    if hasattr(self, "_body"):
        body = self._body
    if body is not None:
        async def cached_receive() -> Message:
            return dict(type="http.request", body=body)
        return cached_receive
    return self._receive