Class AbstractReactiveInterceptor<T,R>

java.lang.Object

io.micronaut.data.runtime.intercept.AbstractQueryInterceptor<T,R>

io.micronaut.data.runtime.intercept.reactive.AbstractReactiveInterceptor<T,R>

Type Parameters:

T - The declaring type

R - The return type

All Implemented Interfaces:

DataInterceptor<T,R>

Direct Known Subclasses:

AbstractPublisherInterceptor, DefaultDeleteAllReactiveInterceptor, DefaultDeleteOneReactiveInterceptor, DefaultInsertAllReactiveInterceptor, DefaultInsertEntityReactiveInterceptor, DefaultInsertOneReactiveInterceptor, DefaultSaveAllReactiveInterceptor, DefaultSaveEntityReactiveInterceptor, DefaultSaveOneReactiveInterceptor, DefaultUpdateAllEntitiesReactiveInterceptor, DefaultUpdateEntityReactiveInterceptor

public abstract class AbstractReactiveInterceptor<T,R>
extends AbstractQueryInterceptor<T,R>

Abstract reactive repository interceptor.

Since:

1.0.0

Author:

graemerocher

Nested Class Summary

Nested classes/interfaces inherited from class AbstractQueryInterceptor

AbstractQueryInterceptor.SaveOperation

Field Summary

Fields

Modifier and Type	Field	Description
protected final @NonNull ReactiveRepositoryOperations	reactiveOperations

Fields inherited from class AbstractQueryInterceptor

conversionService, operations, preparedQueryResolver

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	AbstractReactiveInterceptor(@NonNull RepositoryOperations operations)	Default constructor.

Method Summary

Modifier and Type	Method	Description
protected org.reactivestreams.Publisher<Integer>	count(org.reactivestreams.Publisher<?> publisher)	Count the items.
protected final <E> org.reactivestreams.Publisher<E>	persistOrUpdateReactive(io.micronaut.aop.MethodInvocationContext<T,?> context, E entity)
protected final <E> org.reactivestreams.Publisher<E>	persistWithUpdateFallbackReactive(io.micronaut.aop.MethodInvocationContext<T,?> context, E entity)

Methods inherited from class AbstractQueryInterceptor

convertOne, convertOne, count, findEntitiesParameter, findEntityParameter, findRepositoryOperations, getDeleteAllBatchOperation, getDeleteBatchOperation, getDeleteBatchOperation, getDeleteOperation, getDeleteReturningBatchOperation, getDeleteReturningOperation, getEntitiesParameter, getEntityParameter, getInsertBatchOperation, getInsertBatchOperation, getInsertOperation, getInsertOperation, getLimit, getOffset, getPageable, getPageableInRole, getPagedQuery, getParameterInRole, getParameterInRole, getParametersInRole, getParametersInRole, getParameterValueMap, getRequiredEntity, getRequiredParameterInRole, getRequiredRootEntity, getReturnType, getUpdateAllBatchOperation, getUpdateOperation, getUpdateOperation, hasEntityId, hasReturnTypeInRole, instantiateEntity, isEntityExistsException, isEntityUpdateCandidate, isNumber, isSaveAsInsert, isSaveAssignedIdFallbackToUpdate, persistOrUpdate, persistWithUpdateFallback, prepareCountQuery, prepareQuery, propagate, resolveSaveOperation, unwrapCompletionException, validateNullArguments

Methods inherited from class Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface DataInterceptor

intercept

Field Details

reactiveOperations

protected final @NonNull ReactiveRepositoryOperations reactiveOperations

Constructor Details

AbstractReactiveInterceptor

protected AbstractReactiveInterceptor(@NonNull RepositoryOperations operations)

Default constructor.

Parameters:

operations - The operations

Method Details

count

protected org.reactivestreams.Publisher<Integer> count(org.reactivestreams.Publisher<?> publisher)

Count the items.

Parameters:

publisher - the publisher

Returns:

the size

persistOrUpdateReactive

protected final <E>
org.reactivestreams.Publisher<E> persistOrUpdateReactive(io.micronaut.aop.MethodInvocationContext<T,?> context,
 E entity)

persistWithUpdateFallbackReactive

protected final <E>
org.reactivestreams.Publisher<E> persistWithUpdateFallbackReactive(io.micronaut.aop.MethodInvocationContext<T,?> context,
 E entity)