org.hswebframework.web.crud.events

Class EntityEventHelper

java.lang.Object

org.hswebframework.web.crud.events.EntityEventHelper

public class EntityEventHelper
extends Object

实体事件帮助器

Since:

4.0.12

Author:

zhouhao

Constructor Summary

Constructors

Constructor and Description
EntityEventHelper()

Method Summary

Modifier and Type	Method and Description
static reactor.core.publisher.Mono<Boolean>	isDoFireEvent(boolean defaultIfEmpty) 判断当前是否设置了事件
static <T> reactor.core.publisher.Mono<Void>	publishCreatedEvent(Object source, Class<T> entityType, List<T> entities, Consumer<GenericsPayloadApplicationEvent<EntityCreatedEvent<T>>> publisher)
static <T> reactor.core.publisher.Mono<Void>	publishDeletedEvent(Object source, Class<T> entityType, List<T> entities, Consumer<GenericsPayloadApplicationEvent<EntityDeletedEvent<T>>> publisher)
static <T,E extends AsyncEvent> reactor.core.publisher.Mono<Void>	publishEvent(Object source, Class<T> entityType, Supplier<E> eventSupplier, Consumer<GenericsPayloadApplicationEvent<E>> publisher)
static <T extends Entity> reactor.core.publisher.Mono<Void>	publishModifyEvent(Object source, Class<T> entityType, List<T> before, Consumer<T> afterTransfer, Consumer<GenericsPayloadApplicationEvent<EntityModifyEvent<T>>> publisher)
static <T> reactor.core.publisher.Mono<Void>	publishModifyEvent(Object source, Class<T> entityType, List<T> before, List<T> after, Consumer<GenericsPayloadApplicationEvent<EntityModifyEvent<T>>> publisher)
static <T> reactor.core.publisher.Mono<Void>	publishSavedEvent(Object source, Class<T> entityType, List<T> entities, Consumer<GenericsPayloadApplicationEvent<EntitySavedEvent<T>>> publisher)
static <T> reactor.core.publisher.Flux<T>	setDoNotFireEvent(reactor.core.publisher.Flux<T> stream) 设置Flux不触发实体类事件
static <T> reactor.core.publisher.Mono<T>	setDoNotFireEvent(reactor.core.publisher.Mono<T> stream) 设置Mono不触发实体类事件

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

EntityEventHelper

public EntityEventHelper()

Method Detail

isDoFireEvent

public static reactor.core.publisher.Mono<Boolean> isDoFireEvent(boolean defaultIfEmpty)

判断当前是否设置了事件

Parameters:

defaultIfEmpty - 如果未设置时的默认值

Returns:

是否设置了事件

setDoNotFireEvent

public static <T> reactor.core.publisher.Mono<T> setDoNotFireEvent(reactor.core.publisher.Mono<T> stream)

设置Mono不触发实体类事件

     save(...)
     .as(EntityEventHelper::setDoNotFireEvent)
 

Type Parameters:

T - 泛型

Parameters:

stream - 流

Returns:

流

setDoNotFireEvent

public static <T> reactor.core.publisher.Flux<T> setDoNotFireEvent(reactor.core.publisher.Flux<T> stream)

设置Flux不触发实体类事件

     fetch()
     .as(EntityEventHelper::setDoNotFireEvent)
 

Type Parameters:

T - 泛型

Parameters:

stream - 流

Returns:

流

publishSavedEvent

public static <T> reactor.core.publisher.Mono<Void> publishSavedEvent(Object source,
                                                                      Class<T> entityType,
                                                                      List<T> entities,
                                                                      Consumer<GenericsPayloadApplicationEvent<EntitySavedEvent<T>>> publisher)

publishModifyEvent

public static <T extends Entity> reactor.core.publisher.Mono<Void> publishModifyEvent(Object source,
                                                                                      Class<T> entityType,
                                                                                      List<T> before,
                                                                                      Consumer<T> afterTransfer,
                                                                                      Consumer<GenericsPayloadApplicationEvent<EntityModifyEvent<T>>> publisher)

publishModifyEvent

public static <T> reactor.core.publisher.Mono<Void> publishModifyEvent(Object source,
                                                                       Class<T> entityType,
                                                                       List<T> before,
                                                                       List<T> after,
                                                                       Consumer<GenericsPayloadApplicationEvent<EntityModifyEvent<T>>> publisher)

publishDeletedEvent

public static <T> reactor.core.publisher.Mono<Void> publishDeletedEvent(Object source,
                                                                        Class<T> entityType,
                                                                        List<T> entities,
                                                                        Consumer<GenericsPayloadApplicationEvent<EntityDeletedEvent<T>>> publisher)

publishCreatedEvent

public static <T> reactor.core.publisher.Mono<Void> publishCreatedEvent(Object source,
                                                                        Class<T> entityType,
                                                                        List<T> entities,
                                                                        Consumer<GenericsPayloadApplicationEvent<EntityCreatedEvent<T>>> publisher)

publishEvent

public static <T,E extends AsyncEvent> reactor.core.publisher.Mono<Void> publishEvent(Object source,
                                                                                      Class<T> entityType,
                                                                                      Supplier<E> eventSupplier,
                                                                                      Consumer<GenericsPayloadApplicationEvent<E>> publisher)