io.micronaut.r2dbc.rxjava2

Interface RxConnectionFactory.RxConnectionFunction<T>

Type Parameters:

T - The emitted type

All Superinterfaces:

java.util.function.Function<RxConnection,io.reactivex.Flowable<T>>

Enclosing interface:

RxConnectionFactory

Functional Interface:

This is a functional interface and can therefore be used as the assignment target for a lambda expression or method reference.

@FunctionalInterface
public static interface RxConnectionFactory.RxConnectionFunction<T>
extends java.util.function.Function<RxConnection,io.reactivex.Flowable<T>>

Function applied with a connection.

Method Summary

Modifier and Type	Method and Description
io.reactivex.Flowable<T>	apply(RxConnection rxConnection)

Methods inherited from interface java.util.function.Function

andThen, compose, identity

Method Detail

apply

@NonNull
io.reactivex.Flowable<T> apply(@NonNull
                                        RxConnection rxConnection)

Specified by:

apply in interface java.util.function.Function<RxConnection,io.reactivex.Flowable<T>>