Package io.micronaut.data.connection.sync

Class SynchronousConnectionOperationsFromReactiveConnectionOperations<T>

java.lang.Object

io.micronaut.data.connection.sync.SynchronousConnectionOperationsFromReactiveConnectionOperations<T>

Type Parameters:

T - The connection type

All Implemented Interfaces:

ConnectionOperations<T>

@Internal
public final class SynchronousConnectionOperationsFromReactiveConnectionOperations<T>
extends Object
implements ConnectionOperations<T>

Implementation of the synchronous connection operations using a reactive connection operations.

Since:

4.0.0

Author:

Denis Stepanov

Constructor Summary

Constructors

Constructor	Description
SynchronousConnectionOperationsFromReactiveConnectionOperations(ReactorConnectionOperations<T> reactorConnectionOperations, ExecutorService blockingExecutorService)

Method Summary

Modifier and Type	Method	Description
<R> R	execute(ConnectionDefinition definition, Function<ConnectionStatus<T>,R> callback)	Execute a connection within the context of the function.
Optional<ConnectionStatus<T>>	findConnectionStatus()	Obtains the current connection.
boolean	managesConnection(ConnectionStatus<T> connectionStatus)	Determine whether the given connection status refers to a connection managed by this ConnectionOperations instance.

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.connection.ConnectionOperations

executeRead, executeWrite, getConnectionStatus

Constructor Details

SynchronousConnectionOperationsFromReactiveConnectionOperations

public SynchronousConnectionOperationsFromReactiveConnectionOperations(ReactorConnectionOperations<T> reactorConnectionOperations,
 ExecutorService blockingExecutorService)

Method Details

findConnectionStatus

public Optional<ConnectionStatus<T>> findConnectionStatus()

Description copied from interface: ConnectionOperations

Obtains the current connection.

Specified by:

findConnectionStatus in interface ConnectionOperations<T>

Returns:

The optional connection

execute

public <R> R execute(ConnectionDefinition definition,
 Function<ConnectionStatus<T>,R> callback)

Description copied from interface: ConnectionOperations

Execute a connection within the context of the function.

Specified by:

execute in interface ConnectionOperations<T>

Type Parameters:

R - The result

Parameters:

definition - The connection definition

callback - The call back

Returns:

The result

managesConnection

public boolean managesConnection(ConnectionStatus<T> connectionStatus)

Description copied from interface: ConnectionOperations

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

Specified by:

managesConnection in interface ConnectionOperations<T>

Parameters:

connectionStatus - The connection status to verify

Returns:

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