Package io.micronaut.data.connection.reactive

Class DefaultReactiveConnectionStatus<C>

java.lang.Object

io.micronaut.data.connection.reactive.DefaultReactiveConnectionStatus<C>

Type Parameters:

C - The connection type

All Implemented Interfaces:

ConnectionStatus<C>, ReactiveConnectionStatus<C>

@Internal
public final class DefaultReactiveConnectionStatus<C>
extends Object
implements ReactiveConnectionStatus<C>

The default reactive connection status.

Since:

4.2.0

Author:

Denis Stepanov

Constructor Summary

Constructors

Constructor	Description
DefaultReactiveConnectionStatus(C connection, ConnectionDefinition definition, boolean isNew)

Method Summary

Modifier and Type	Method	Description
C	getConnection()	The connection representation.
ConnectionDefinition	getDefinition()	The connection definition.
boolean	isNew()	A new connection value.
org.reactivestreams.Publisher<Void>	onCancel(Supplier<org.reactivestreams.Publisher<Void>> closeConnection)
org.reactivestreams.Publisher<Void>	onComplete(Supplier<org.reactivestreams.Publisher<Void>> closeConnection)
org.reactivestreams.Publisher<Void>	onError(Throwable outterThrowable, Supplier<org.reactivestreams.Publisher<Void>> closeConnection)
void	registerReactiveSynchronization(ReactiveConnectionSynchronization synchronization)	Register reactive connection synchronization.
void	registerSynchronization(ConnectionSynchronization synchronization)	Register connection synchronization.

Methods inherited from class java.lang.Object

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

Constructor Details

DefaultReactiveConnectionStatus

public DefaultReactiveConnectionStatus(C connection,
 ConnectionDefinition definition,
 boolean isNew)

Method Details

isNew

public boolean isNew()

Description copied from interface: ConnectionStatus

A new connection value. Based on the propagation value the connection manager might decide to reuse the existing connection.

Specified by:

isNew in interface ConnectionStatus<C>

Returns:

true if the connection is new

getConnection

public C getConnection()

Description copied from interface: ConnectionStatus

The connection representation.

Specified by:

getConnection in interface ConnectionStatus<C>

Returns:

The connection representation

getDefinition

public ConnectionDefinition getDefinition()

Description copied from interface: ConnectionStatus

The connection definition.

Specified by:

getDefinition in interface ConnectionStatus<C>

Returns:

The connection definition

registerSynchronization

public void registerSynchronization(ConnectionSynchronization synchronization)

Description copied from interface: ConnectionStatus

Register connection synchronization.

Specified by:

registerSynchronization in interface ConnectionStatus<C>

Parameters:

synchronization - The synchronization

registerReactiveSynchronization

public void registerReactiveSynchronization(ReactiveConnectionSynchronization synchronization)

Description copied from interface: ReactiveConnectionStatus

Register reactive connection synchronization.

Specified by:

registerReactiveSynchronization in interface ReactiveConnectionStatus<C>

Parameters:

synchronization - The synchronization

onComplete

public org.reactivestreams.Publisher<Void> onComplete(Supplier<org.reactivestreams.Publisher<Void>> closeConnection)

onError

public org.reactivestreams.Publisher<Void> onError(Throwable outterThrowable,
 Supplier<org.reactivestreams.Publisher<Void>> closeConnection)

onCancel

public org.reactivestreams.Publisher<Void> onCancel(Supplier<org.reactivestreams.Publisher<Void>> closeConnection)