Class AbstractReactiveSpecificationInterceptor<T,R>

java.lang.Object
io.micronaut.data.runtime.intercept.AbstractQueryInterceptor<T,R>
io.micronaut.data.runtime.intercept.criteria.AbstractSpecificationInterceptor<T,R>
io.micronaut.data.runtime.intercept.criteria.reactive.AbstractReactiveSpecificationInterceptor<T,R>
Type Parameters:
T - The declaring type
R - The return type
All Implemented Interfaces:
DataInterceptor<T,R>
Direct Known Subclasses:
CountReactiveSpecificationInterceptor, DeleteAllReactiveSpecificationInterceptor, ExistsReactiveSpecificationInterceptor, FindAllReactiveSpecificationInterceptor, FindOneReactiveSpecificationInterceptor, FindPageReactiveSpecificationInterceptor, UpdateAllReactiveSpecificationInterceptor

public abstract class AbstractReactiveSpecificationInterceptor<T,R> extends AbstractSpecificationInterceptor<T,R>
Abstract reactive specification interceptor.
Since:
3.2
Author:
Denis Stepanov
  • Field Details

  • Constructor Details

    • AbstractReactiveSpecificationInterceptor

      protected AbstractReactiveSpecificationInterceptor(RepositoryOperations operations)
      Default constructor.
      Parameters:
      operations - The operations
  • Method Details

    • findAllReactive

      @NonNull protected final @NonNull org.reactivestreams.Publisher<Object> findAllReactive(RepositoryMethodKey methodKey, io.micronaut.aop.MethodInvocationContext<T,R> context, AbstractSpecificationInterceptor.Type type)
    • findOneReactive

      @NonNull protected final @NonNull org.reactivestreams.Publisher<Object> findOneReactive(RepositoryMethodKey methodKey, io.micronaut.aop.MethodInvocationContext<T,R> context, AbstractSpecificationInterceptor.Type type)
    • countReactive

      @NonNull protected final @NonNull org.reactivestreams.Publisher<Long> countReactive(RepositoryMethodKey methodKey, io.micronaut.aop.MethodInvocationContext<T,R> context)
    • existsReactive

      protected final org.reactivestreams.Publisher<Boolean> existsReactive(RepositoryMethodKey methodKey, io.micronaut.aop.MethodInvocationContext<T,R> context)
    • deleteAllReactive

      protected final org.reactivestreams.Publisher<Number> deleteAllReactive(RepositoryMethodKey methodKey, io.micronaut.aop.MethodInvocationContext<T,R> context)
    • updateAllReactive

      protected final org.reactivestreams.Publisher<Number> updateAllReactive(RepositoryMethodKey methodKey, io.micronaut.aop.MethodInvocationContext<T,R> context)