async def METHOD_NAME() -> None:
    r = receiver.Receiver(proto)
    partial = await r.consume('{"msgtype": "PATCH-DOC", "msgid": "10", "num_buffers":1}')
    assert partial is None
    partial = await r.consume('{}')
    assert partial is None
    partial = await r.consume('{"bar": 10}')
    assert partial is None
    partial = await r.consume('{"id": "buf_header"}')
    assert partial is None
    partial = await r.consume(b'payload')
    assert partial is not None
    assert partial.msgtype == "PATCH-DOC"
    assert partial.header == {"msgtype": "PATCH-DOC", "msgid": "10", "num_buffers":1}
    assert partial.content == {"bar":10}
    assert partial.metadata == {}
    assert partial.buffers == [Buffer(ID("buf_header"), b"payload")]