async def METHOD_NAME() -> None:
    r = receiver.Receiver(proto)
    await r.consume('{"msgtype": "PATCH-DOC", "msgid": "10"}')
    await r.consume('metadata')
    with pytest.raises(ValidationError):
        await r.consume(b'content')