io.micronaut.r2dbc.rxjava2

Interface RxConnectionFactory

All Superinterfaces:

io.r2dbc.spi.ConnectionFactory

public interface RxConnectionFactory
extends io.r2dbc.spi.ConnectionFactory

Specialization of ConnectionFactory for RxJava.

Since:

1.0.0

Author:

graemerocher

Nested Class Summary

Nested Classes

Modifier and Type	Interface and Description
static interface	RxConnectionFactory.RxConnectionFunction<T> Function applied with a connection.

Method Summary

Modifier and Type	Method and Description
io.reactivex.Flowable<? extends RxConnection>	create() Creates a new RxConnection.
<T> io.reactivex.Flowable<T>	withConnection(RxConnectionFactory.RxConnectionFunction<T> publisherFunction) Apply the given function closing the connection on termination.
<T> io.reactivex.Flowable<T>	withTransaction(RxConnectionFactory.RxConnectionFunction<T> publisherFunction) Apply given function within a context of a transaction, rolling back if an error occurs and committing if not.

Methods inherited from interface io.r2dbc.spi.ConnectionFactory

getMetadata

Method Detail

create

@NonNull
io.reactivex.Flowable<? extends RxConnection> create()

Creates a new RxConnection.

Specified by:

create in interface io.r2dbc.spi.ConnectionFactory

Returns:

the newly created RxConnection

withConnection

@NonNull
<T> io.reactivex.Flowable<T> withConnection(@NonNull
                                                     RxConnectionFactory.RxConnectionFunction<T> publisherFunction)

Apply the given function closing the connection on termination.

Type Parameters:

T - The return type

Parameters:

publisherFunction - The publisher function

Returns:

The flowable

withTransaction

@NonNull
<T> io.reactivex.Flowable<T> withTransaction(@NonNull
                                                      RxConnectionFactory.RxConnectionFunction<T> publisherFunction)

Apply given function within a context of a transaction, rolling back if an error occurs and committing if not. This method will also close the connection on completion.

Type Parameters:

T - The return type

Parameters:

publisherFunction - The publisher function

Returns:

The flowable