Class AbstractReactorConnectionOperations<C>

java.lang.Object

io.micronaut.data.connection.support.AbstractReactorConnectionOperations<C>

Type Parameters:

C - The connection type

All Implemented Interfaces:

ReactiveStreamsConnectionOperations<C>, ReactorConnectionOperations<C>

Direct Known Subclasses:

DefaultR2dbcReactorConnectionOperations

@Internal
public abstract class AbstractReactorConnectionOperations<C>
extends Object
implements ReactorConnectionOperations<C>

The reactive MongoDB connection operations implementation.

Since:

4.0.0

Author:

Denis Stepanov

Constructor Summary

Constructors

Constructor	Description
AbstractReactorConnectionOperations()

Method Summary

Modifier and Type	Method	Description
protected abstract @NonNull org.reactivestreams.Publisher<Void>	closeConnection(@NonNull C connection, @NonNull ConnectionDefinition definition)	Close the connection.
final Optional<ConnectionStatus<C>>	findConnectionStatus(@NonNull reactor.util.context.ContextView contextView)	Obtains the current connection.
boolean	managesConnection(ConnectionStatus<C> connectionStatus)	Determine whether the given connection status refers to a connection managed by this ReactiveStreamsConnectionOperations instance.
protected abstract @NonNull org.reactivestreams.Publisher<C>	openConnection(@NonNull ConnectionDefinition definition)	Open a new connection.
<T> @NonNull reactor.core.publisher.Flux<T>	withConnectionFlux(@NonNull ConnectionDefinition definition, @NonNull Function<ConnectionStatus<C>, reactor.core.publisher.Flux<T>> callback)	Execute the given handler with a new transaction.
<T> @NonNull reactor.core.publisher.Mono<T>	withConnectionMono(@NonNull ConnectionDefinition definition, @NonNull Function<ConnectionStatus<C>, reactor.core.publisher.Mono<T>> callback)	Execute the given handler with a new connection.

Methods inherited from class Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface ReactiveStreamsConnectionOperations

withConnection

Methods inherited from interface ReactorConnectionOperations

getConnectionStatus, withConnection, withConnectionFlux, withConnectionMono

Constructor Details

AbstractReactorConnectionOperations

public AbstractReactorConnectionOperations()

Method Details

openConnection

protected abstract @NonNull org.reactivestreams.Publisher<C> openConnection(@NonNull ConnectionDefinition definition)

Open a new connection.

Parameters:

definition - The connection definition

Returns:

new connection publisher

closeConnection

protected abstract @NonNull org.reactivestreams.Publisher<Void> closeConnection(@NonNull C connection,
 @NonNull ConnectionDefinition definition)

Close the connection.

Parameters:

connection - The connection

definition - The connection definition

Returns:

closed publisher

managesConnection

public boolean managesConnection(ConnectionStatus<C> connectionStatus)

Description copied from interface: ReactiveStreamsConnectionOperations

Determine whether the given connection status refers to a connection managed by this ReactiveStreamsConnectionOperations instance.

Specified by:

managesConnection in interface ReactiveStreamsConnectionOperations<C>

Parameters:

connectionStatus - The connection status to verify

Returns:

true if the connection is managed (i.e. created/supplied) by this operations instance

findConnectionStatus

public final Optional<ConnectionStatus<C>> findConnectionStatus(@NonNull reactor.util.context.ContextView contextView)

Description copied from interface: ReactorConnectionOperations

Obtains the current connection.

Specified by:

findConnectionStatus in interface ReactorConnectionOperations<C>

Parameters:

contextView - The reactor's context view

Returns:

The optional connection

withConnectionFlux

public <T> @NonNull reactor.core.publisher.Flux<T> withConnectionFlux(@NonNull ConnectionDefinition definition,
 @NonNull Function<ConnectionStatus<C>, 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<C>

Type Parameters:

T - The emitted type

Parameters:

definition - The definition

callback - The handler

Returns:

A publisher that emits the result type

withConnectionMono

public <T> @NonNull reactor.core.publisher.Mono<T> withConnectionMono(@NonNull ConnectionDefinition definition,
 @NonNull Function<ConnectionStatus<C>, 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<C>

Type Parameters:

T - The emitted type

Parameters:

definition - The definition

callback - The handler

Returns:

A publisher that emits the result type