Class ReactiveCountSpecificationInterceptor
java.lang.Object
io.micronaut.data.runtime.intercept.AbstractQueryInterceptor<T,R>
io.micronaut.data.runtime.intercept.reactive.AbstractReactiveInterceptor<Object,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<Object,
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
conversionService, preparedQueryResolver
-
Constructor Summary
ConstructorDescriptionReactiveCountSpecificationInterceptor
(@NonNull RepositoryOperations operations) Default constructor. -
Method Summary
Modifier and TypeMethodDescriptionprotected org.reactivestreams.Publisher<?>
interceptPublisher
(RepositoryMethodKey methodKey, io.micronaut.aop.MethodInvocationContext<Object, 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
convertOne, convertOne, count, findEntitiesParameter, findEntityParameter, getDeleteAllBatchOperation, getDeleteBatchOperation, getDeleteBatchOperation, getDeleteOperation, getDeleteReturningBatchOperation, getDeleteReturningOperation, getEntitiesParameter, getEntityParameter, getInsertBatchOperation, getInsertBatchOperation, getInsertOperation, getInsertOperation, getLimit, getOffset, getPageable, getPageableInRole, getPagedQuery, getParameterInRole, getParameterValueMap, getRequiredEntity, getRequiredParameterInRole, getRequiredRootEntity, getReturnType, getUpdateAllBatchOperation, getUpdateOperation, getUpdateOperation, instantiateEntity, isNullable, isNumber, prepareCountQuery, prepareQuery, validateNullArguments
-
Constructor Details
-
ReactiveCountSpecificationInterceptor
Default constructor.- Parameters:
operations
- The operations
-
-
Method Details
-
interceptPublisher
protected org.reactivestreams.Publisher<?> interceptPublisher(RepositoryMethodKey methodKey, io.micronaut.aop.MethodInvocationContext<Object, 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
-