Class DefaultSaveAllReactiveInterceptor

All Implemented Interfaces:
DataInterceptor<Object,Object>, SaveAllReactiveInterceptor<Object,Object>

public class DefaultSaveAllReactiveInterceptor extends AbstractReactiveInterceptor<Object,Object> implements SaveAllReactiveInterceptor<Object,Object>
Default implementation of SaveAllReactiveInterceptor.
Since:
1.0.0
Author:
graemerocher
  • Constructor Details

    • DefaultSaveAllReactiveInterceptor

      protected DefaultSaveAllReactiveInterceptor(@NonNull @NonNull RepositoryOperations operations)
      Default constructor.
      Parameters:
      operations - The operations
  • Method Details

    • interceptPublisher

      public org.reactivestreams.Publisher<?> interceptPublisher(RepositoryMethodKey methodKey, io.micronaut.aop.MethodInvocationContext<Object,Object> context)
      Intercept publisher.
      Parameters:
      methodKey - The method key
      context - The context
      Returns:
      the result publisher
    • intercept

      public final Object intercept(RepositoryMethodKey methodKey, io.micronaut.aop.MethodInvocationContext<Object,Object> context)
      Description copied from interface: DataInterceptor
      Intercepts a data method execution.
      Parameters:
      methodKey - The method key
      context - The context
      Returns:
      The result