Package io.micronaut.data.r2dbc.connection

Class DefaultR2DbcReactorConnectionOperations

java.lang.Object
io.micronaut.data.r2dbc.connection.DefaultR2DbcReactorConnectionOperations
All Implemented Interfaces:
ReactiveStreamsConnectionOperations<io.r2dbc.spi.Connection>, ReactorConnectionOperations<io.r2dbc.spi.Connection>
@EachBean(io.r2dbc.spi.ConnectionFactory.class) @Internal public final class DefaultR2DbcReactorConnectionOperations extends Object implements ReactorConnectionOperations<io.r2dbc.spi.Connection>
The reactive R2DBC connection operations implementation.
Since:
3.3
Author:
Denis Stepanov

  • Method Details

    • findConnectionStatus

      public Optional<ConnectionStatus<io.r2dbc.spi.Connection>> findConnectionStatus(reactor.util.context.ContextView contextView)
      Description copied from interface: ReactorConnectionOperations
      Obtains the current connection.
      Specified by:
      findConnectionStatus in interface ReactorConnectionOperations<io.r2dbc.spi.Connection>
      Parameters:
      contextView - The reactor's context view
      Returns:
      The optional connection

    • withConnectionFluxWithCloseCallback

      public <T> reactor.core.publisher.Flux<T> withConnectionFluxWithCloseCallback(@NonNull @NonNull ConnectionDefinition definition, @NonNull @NonNull BiFunction<ConnectionStatus<io.r2dbc.spi.Connection>,Supplier<org.reactivestreams.Publisher<Void>>,org.reactivestreams.Publisher<T>> callback)

    • withConnectionFlux

      @NonNull public <T> @NonNull reactor.core.publisher.Flux<T> withConnectionFlux(@NonNull @NonNull ConnectionDefinition definition, @NonNull @NonNull Function<ConnectionStatus<io.r2dbc.spi.Connection>,reactor.core.publisher.Flux<T>> callback)
      Description copied from interface: ReactorConnectionOperations
      Execute the given handler with a new transaction.
      Specified by:
      withConnectionFlux in interface ReactorConnectionOperations<io.r2dbc.spi.Connection>
      Type Parameters:
      T - The emitted type
      Parameters:
      definition - The definition
      callback - The handler
      Returns:
      A publisher that emits the result type

    • withConnectionMono

      @NonNull public <T> @NonNull reactor.core.publisher.Mono<T> withConnectionMono(@NonNull @NonNull ConnectionDefinition definition, @NonNull @NonNull Function<ConnectionStatus<io.r2dbc.spi.Connection>,reactor.core.publisher.Mono<T>> callback)
      Description copied from interface: ReactorConnectionOperations
      Execute the given handler with a new connection.
      Specified by:
      withConnectionMono in interface ReactorConnectionOperations<io.r2dbc.spi.Connection>
      Type Parameters:
      T - The emitted type
      Parameters:
      definition - The definition
      callback - The handler
      Returns:
      A publisher that emits the result type