Class ReactiveCountSpecificationInterceptor
- java.lang.Object
-
- io.micronaut.data.runtime.intercept.AbstractQueryInterceptor<T,R>
-
- io.micronaut.data.runtime.intercept.reactive.AbstractReactiveInterceptor<java.lang.Object,java.lang.Object>
-
- io.micronaut.data.runtime.intercept.reactive.AbstractPublisherInterceptor
-
- io.micronaut.data.hibernate.reactive.repository.jpa.intercept.AbstractSpecificationInterceptor
-
- io.micronaut.data.hibernate.reactive.repository.jpa.intercept.ReactiveCountSpecificationInterceptor
-
- All Implemented Interfaces:
DataInterceptor<java.lang.Object,java.lang.Object>
@Internal public class ReactiveCountSpecificationInterceptor extends AbstractSpecificationInterceptor
Interceptor that supports count specifications.- Since:
- 3.5.0
- Author:
- Denis Stepanov
-
-
Field Summary
-
Fields inherited from class io.micronaut.data.hibernate.reactive.repository.jpa.intercept.AbstractSpecificationInterceptor
operations
-
Fields inherited from class io.micronaut.data.runtime.intercept.reactive.AbstractReactiveInterceptor
reactiveOperations
-
Fields inherited from class io.micronaut.data.runtime.intercept.AbstractQueryInterceptor
preparedQueryResolver
-
-
Constructor Summary
Constructors Constructor Description ReactiveCountSpecificationInterceptor(RepositoryOperations operations)
Default constructor.
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description protected org.reactivestreams.Publisher<?>
interceptPublisher(RepositoryMethodKey methodKey, io.micronaut.aop.MethodInvocationContext<java.lang.Object,java.lang.Object> context)
Intercept publisher.-
Methods inherited from class io.micronaut.data.hibernate.reactive.repository.jpa.intercept.AbstractSpecificationInterceptor
getOrders, getSpecification
-
Methods inherited from class io.micronaut.data.runtime.intercept.reactive.AbstractPublisherInterceptor
intercept
-
Methods inherited from class io.micronaut.data.runtime.intercept.reactive.AbstractReactiveInterceptor
count
-
Methods inherited from class io.micronaut.data.runtime.intercept.AbstractQueryInterceptor
convertNumberArgumentIfNecessary, convertOne, convertOne, count, findEntitiesParameter, findEntityParameter, getDeleteAllBatchOperation, getDeleteBatchOperation, getDeleteBatchOperation, getDeleteOperation, getEntitiesParameter, getEntityParameter, getInsertBatchOperation, getInsertBatchOperation, getInsertOperation, getInsertOperation, getPageable, getPagedQuery, getParameterValueMap, getRequiredEntity, getRequiredRootEntity, getReturnType, getUpdateAllBatchOperation, getUpdateOperation, getUpdateOperation, instantiateEntity, isNullable, isNumber, prepareCountQuery, prepareQuery, prepareQuery, prepareQuery, validateNullArguments
-
-
-
-
Constructor Detail
-
ReactiveCountSpecificationInterceptor
public ReactiveCountSpecificationInterceptor(@NonNull RepositoryOperations operations)
Default constructor.- Parameters:
operations
- The operations
-
-
Method Detail
-
interceptPublisher
protected org.reactivestreams.Publisher<?> interceptPublisher(RepositoryMethodKey methodKey, io.micronaut.aop.MethodInvocationContext<java.lang.Object,java.lang.Object> context)
Description copied from class:AbstractPublisherInterceptor
Intercept publisher.- Specified by:
interceptPublisher
in classAbstractPublisherInterceptor
- Parameters:
methodKey
- The method keycontext
- The context- Returns:
- the result publisher
-
-