async def METHOD_NAME() -> None:
    r = receiver.Receiver(proto)
    await r.consume('{"msgtype": "PATCH-DOC", "msgid": "10", "num_buffers":1}')
    await r.consume('{}')
    await r.consume('{}')
    await r.consume('{"id": "buf_header"}')
    with pytest.raises(ValidationError):
        await r.consume('buf_payload')