Class DefaultFindCursoredPageReactiveInterceptor
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.runtime.intercept.reactive.DefaultFindCursoredPageReactiveInterceptor
- All Implemented Interfaces:
DataInterceptor<Object,
,Object> FindCursoredReactivePageInterceptor<Object,
Object>
@Internal
public final class DefaultFindCursoredPageReactiveInterceptor
extends AbstractPublisherInterceptor
implements FindCursoredReactivePageInterceptor<Object,Object>
Default implementation of
FindCursoredReactivePageInterceptor
delegating to findPage
.- Since:
- 4.13
- Author:
- Denis Stepanov
-
Field Summary
Fields inherited from class io.micronaut.data.runtime.intercept.reactive.AbstractReactiveInterceptor
reactiveOperations
Fields inherited from class io.micronaut.data.runtime.intercept.AbstractQueryInterceptor
conversionService, operations, preparedQueryResolver
-
Constructor Summary
ConstructorsConstructorDescriptionDefaultFindCursoredPageReactiveInterceptor
(@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.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, getParametersInRole, getParameterValueMap, getRequiredEntity, getRequiredParameterInRole, getRequiredRootEntity, getReturnType, getUpdateAllBatchOperation, getUpdateOperation, getUpdateOperation, instantiateEntity, isNullable, isNumber, prepareCountQuery, 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
-
Constructor Details
-
DefaultFindCursoredPageReactiveInterceptor
public DefaultFindCursoredPageReactiveInterceptor(@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
-