@Override
    public String getId() {
        return "entity-listener";
    }
@Test
    public void testPrepareModify() {
        EventTestEntity entity = EventTestEntity.of("prepare", 10);
        reactiveRepository
            .insert(entity)
            .as(StepVerifier::create)
            .expectNext(1)
            .verifyComplete();
        Assert.assertEquals(listener.created.getAndSet(0), 1);

        reactiveRepository
            .createUpdate()
            .set("name", "prepare-xx")
            .set("age", 20)
            .where("id", entity.getId())
            .execute()
            .as(StepVerifier::create)
            .expectNextCount(1)
            .verifyComplete();

        reactiveRepository
            .findById(entity.getId())
            .map(EventTestEntity::getName)
            .as(StepVerifier::create)
            .expectNext("prepare-0")
            .verifyComplete();

    }