public Flux<E> getCacheAll() {
        return getCache().getFlux(ALL_DATA_KEY, () -> EnableCacheReactiveCrudService.super.createQuery().fetch());
    }
@Test
    public void test2() {

        TestEntity entity = TestEntity.of("test1",100,"testName");

        entityService
                .createDelete()
                .notNull(TestEntity::getId)
                .execute()
                .block();

        entityService
                .insert(Mono.just(entity))
                .as(StepVerifier::create)
                .expectNext(1)
                .verifyComplete();

        entityService
                .getCacheAll()
                .as(StepVerifier::create)
                .expectNextCount(1)
                .verifyComplete();

        entity.setAge(120);
        entityService
                .updateById(entity.getId(), entity)
                .as(StepVerifier::create)
                .expectNext(1)
                .verifyComplete();

        entityService
                .getCacheAll()
                .switchIfEmpty(Mono.error(NullPointerException::new))
                .as(StepVerifier::create)
                .expectNextMatches(t -> t.getAge().equals(120))
                .verifyComplete();

        entity.setId(null);
        entityService
                .insert(Mono.just(entity))
                .as(StepVerifier::create)
                .expectNext(1)
                .verifyComplete();

        entityService
                .getCacheAll()
                .as(StepVerifier::create)
                .expectNextCount(2)
                .verifyComplete();

        entityService
                .deleteById(entity.getId())
                .as(StepVerifier::create)
                .expectNextCount(1)
                .verifyComplete();

        entityService
                .getCacheAll()
                .as(StepVerifier::create)
                .expectNextCount(1)
                .verifyComplete();
    }