Package io.micronaut.data.runtime.intercept.reactive

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, 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

Field Summary

Fields

Modifier and Type	Field	Description
protected final @NonNull ReactiveRepositoryOperations	reactiveOperations

Fields inherited from class io.micronaut.data.runtime.intercept.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.

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

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

Field Details

reactiveOperations

@NonNull
protected final @NonNull ReactiveRepositoryOperations reactiveOperations

Constructor Details

AbstractReactiveInterceptor

protected AbstractReactiveInterceptor(@NonNull
 @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