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:

DefaultCountReactiveInterceptor, DefaultDeleteAllReactiveInterceptor, DefaultDeleteOneReactiveInterceptor, DefaultExistsByReactiveInterceptor, DefaultFindAllReactiveInterceptor, DefaultFindByIdReactiveInterceptor, DefaultFindOneReactiveInterceptor, DefaultFindPageReactiveInterceptor, DefaultFindSliceReactiveInterceptor, DefaultSaveAllReactiveInterceptor, DefaultSaveEntityReactiveInterceptor, DefaultSaveOneReactiveInterceptor, DefaultUpdateAllEntitiesReactiveInterceptor, DefaultUpdateEntityReactiveInterceptor, DefaultUpdateReactiveInterceptor

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 and Description
protected ReactiveRepositoryOperations	reactiveOperations

Fields inherited from class io.micronaut.data.runtime.intercept.AbstractQueryInterceptor

operations

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
protected org.reactivestreams.Publisher<java.lang.Integer>	count(org.reactivestreams.Publisher<R> publisher) Count the items.

Methods inherited from class io.micronaut.data.runtime.intercept.AbstractQueryInterceptor

convertNumberArgumentIfNecessary, count, findEntitiesParameter, findEntityParameter, getDeleteBatchOperation, getDeleteBatchOperation, getDeleteOperation, getEntitiesParameter, getEntityParameter, getInsertBatchOperation, getInsertBatchOperation, getInsertOperation, getInsertOperation, getPageable, getPagedQuery, getRequiredEntity, getRequiredRootEntity, getUpdateAllBatchOperation, getUpdateOperation, getUpdateOperation, instantiateEntity, isNullable, isNumber, prepareCountQuery, prepareQuery, 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 Detail

reactiveOperations

@NonNull
protected final ReactiveRepositoryOperations reactiveOperations

Constructor Detail

AbstractReactiveInterceptor

protected AbstractReactiveInterceptor(@NonNull
                                      RepositoryOperations operations)

Default constructor.

Parameters:

operations - The operations

Method Detail

count

protected org.reactivestreams.Publisher<java.lang.Integer> count(org.reactivestreams.Publisher<R> publisher)

Count the items.

Parameters:

publisher - the publisher

Returns:

the size