Class ReactiveFindAllSpecificationInterceptor
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.ReactiveFindAllSpecificationInterceptor
- All Implemented Interfaces:
DataInterceptor<Object,
Object>
@Internal
public class ReactiveFindAllSpecificationInterceptor
extends AbstractSpecificationInterceptor
Implementation of the unpaged version of
findAll(Specification)
.- 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
ModifierConstructorDescriptionprotected
ReactiveFindAllSpecificationInterceptor
(@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
-
ReactiveFindAllSpecificationInterceptor
protected ReactiveFindAllSpecificationInterceptor(@NonNull @NonNull RepositoryOperations operations) 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
-