Class AbstractReactiveSpecificationInterceptor<T,R>
java.lang.Object
io.micronaut.data.runtime.intercept.AbstractQueryInterceptor<T,R>
io.micronaut.data.runtime.intercept.criteria.AbstractSpecificationInterceptor<T,R>
io.micronaut.data.runtime.intercept.criteria.reactive.AbstractReactiveSpecificationInterceptor<T,R>
- Type Parameters:
T
- The declaring typeR
- The return type
- All Implemented Interfaces:
DataInterceptor<T,
R>
- Direct Known Subclasses:
CountReactiveSpecificationInterceptor
,DeleteAllReactiveSpecificationInterceptor
,ExistsReactiveSpecificationInterceptor
,FindAllReactiveSpecificationInterceptor
,FindOneReactiveSpecificationInterceptor
,FindPageReactiveSpecificationInterceptor
,UpdateAllReactiveSpecificationInterceptor
public abstract class AbstractReactiveSpecificationInterceptor<T,R>
extends AbstractSpecificationInterceptor<T,R>
Abstract reactive specification interceptor.
- Since:
- 3.2
- Author:
- Denis Stepanov
-
Nested Class Summary
Nested classes/interfaces inherited from class io.micronaut.data.runtime.intercept.criteria.AbstractSpecificationInterceptor
AbstractSpecificationInterceptor.Type
-
Field Summary
FieldsModifier and TypeFieldDescriptionprotected final ReactiveCriteriaRepositoryOperations
protected final ReactiveRepositoryOperations
Fields inherited from class io.micronaut.data.runtime.intercept.criteria.AbstractSpecificationInterceptor
criteriaRepositoryOperations
Fields inherited from class io.micronaut.data.runtime.intercept.AbstractQueryInterceptor
conversionService, operations, preparedQueryResolver
-
Constructor Summary
ConstructorsModifierConstructorDescriptionprotected
Default constructor. -
Method Summary
Modifier and TypeMethodDescriptionprotected final @NonNull org.reactivestreams.Publisher<Long>
countReactive
(RepositoryMethodKey methodKey, io.micronaut.aop.MethodInvocationContext<T, R> context) protected final org.reactivestreams.Publisher<Number>
deleteAllReactive
(RepositoryMethodKey methodKey, io.micronaut.aop.MethodInvocationContext<T, R> context) protected final org.reactivestreams.Publisher<Boolean>
existsReactive
(RepositoryMethodKey methodKey, io.micronaut.aop.MethodInvocationContext<T, R> context) protected final @NonNull org.reactivestreams.Publisher<Object>
findAllReactive
(RepositoryMethodKey methodKey, io.micronaut.aop.MethodInvocationContext<T, R> context, AbstractSpecificationInterceptor.Type type) protected final @NonNull org.reactivestreams.Publisher<Object>
findOneReactive
(RepositoryMethodKey methodKey, io.micronaut.aop.MethodInvocationContext<T, R> context, AbstractSpecificationInterceptor.Type type) protected final org.reactivestreams.Publisher<Number>
updateAllReactive
(RepositoryMethodKey methodKey, io.micronaut.aop.MethodInvocationContext<T, R> context) Methods inherited from class io.micronaut.data.runtime.intercept.criteria.AbstractSpecificationInterceptor
buildCountQuery, buildDeleteQuery, buildExistsQuery, buildQuery, buildUpdateQuery, count, deleteAll, exists, findAll, findOne, getCriteriaDeleteBuilder, getCriteriaQueryBuilder, getCriteriaUpdateBuilder, getDeleteSpecification, getMethodJoinPaths, getQuerySpecification, getUpdateSpecification, preparedQueryForCriteria, updateAll
Methods inherited from class io.micronaut.data.runtime.intercept.AbstractQueryInterceptor
convertOne, convertOne, count, findEntitiesParameter, findEntityParameter, getDeleteAllBatchOperation, getDeleteBatchOperation, getDeleteBatchOperation, getDeleteOperation, getDeleteReturningBatchOperation, getDeleteReturningOperation, getEntitiesParameter, getEntityParameter, getInsertBatchOperation, getInsertBatchOperation, getInsertOperation, getInsertOperation, getPageable, getPagedQuery, getParameterValueMap, getRequiredEntity, getRequiredRootEntity, getReturnType, getUpdateAllBatchOperation, getUpdateOperation, getUpdateOperation, instantiateEntity, isNullable, isNumber, prepareCountQuery, prepareQuery, prepareQuery, prepareQuery, validateNullArguments
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
Methods inherited from interface io.micronaut.data.intercept.DataInterceptor
intercept
-
Field Details
-
reactiveOperations
-
reactiveCriteriaOperations
-
-
Constructor Details
-
AbstractReactiveSpecificationInterceptor
Default constructor.- Parameters:
operations
- The operations
-
-
Method Details
-
findAllReactive
@NonNull protected final @NonNull org.reactivestreams.Publisher<Object> findAllReactive(RepositoryMethodKey methodKey, io.micronaut.aop.MethodInvocationContext<T, R> context, AbstractSpecificationInterceptor.Type type) -
findOneReactive
@NonNull protected final @NonNull org.reactivestreams.Publisher<Object> findOneReactive(RepositoryMethodKey methodKey, io.micronaut.aop.MethodInvocationContext<T, R> context, AbstractSpecificationInterceptor.Type type) -
countReactive
@NonNull protected final @NonNull org.reactivestreams.Publisher<Long> countReactive(RepositoryMethodKey methodKey, io.micronaut.aop.MethodInvocationContext<T, R> context) -
existsReactive
protected final org.reactivestreams.Publisher<Boolean> existsReactive(RepositoryMethodKey methodKey, io.micronaut.aop.MethodInvocationContext<T, R> context) -
deleteAllReactive
protected final org.reactivestreams.Publisher<Number> deleteAllReactive(RepositoryMethodKey methodKey, io.micronaut.aop.MethodInvocationContext<T, R> context) -
updateAllReactive
protected final org.reactivestreams.Publisher<Number> updateAllReactive(RepositoryMethodKey methodKey, io.micronaut.aop.MethodInvocationContext<T, R> context)
-