org.immutables.criteria.repository.reactive

Class ReactiveReader<T>

java.lang.Object

org.immutables.criteria.repository.AbstractReader<ReactiveReader<T>>

org.immutables.criteria.repository.reactive.ReactiveReader<T>

All Implemented Interfaces:

Fetcher<T>, ReactiveFetcher<T>, Reader<ReactiveReader<T>>

public final class ReactiveReader<T>
extends AbstractReader<ReactiveReader<T>>
implements ReactiveFetcher<T>

Constructor Summary

Constructors

Constructor and Description
ReactiveReader(Query query, Backend.Session session)

Method Summary

Modifier and Type	Method and Description
ReactiveFetcher<T>	changeQuery(UnaryOperator<Query> mapFn)
org.reactivestreams.Publisher<Long>	count()
org.reactivestreams.Publisher<Boolean>	exists()
org.reactivestreams.Publisher<T>	fetch()
<X> ReactiveFetcher<X>	map(Function<? super T,? extends X> mapFn)
protected ReactiveReader<T>	newReader(Query query)
org.reactivestreams.Publisher<T>	one()
org.reactivestreams.Publisher<T>	oneOrNone()
ReactiveMapperTuple	select(Iterable<Projection<?>> projections)
<T1> ReactiveMapper1<T1>	select(Projection<T1> proj1)
<T1,T2> ReactiveMapper2<T1,T2>	select(Projection<T1> proj1, Projection<T2> proj2)
<T1,T2,T3> ReactiveMapper3<T1,T2,T3>	select(Projection<T1> proj1, Projection<T2> proj2, Projection<T3> proj3)
<T1,T2,T3,T4> ReactiveMapper4<T1,T2,T3,T4>	select(Projection<T1> proj1, Projection<T2> proj2, Projection<T3> proj3, Projection<T4> proj4)
<T1,T2,T3,T4,T5> ReactiveMapper5<T1,T2,T3,T4,T5>	select(Projection<T1> proj1, Projection<T2> proj2, Projection<T3> proj3, Projection<T4> proj4, Projection<T5> proj5)

Methods inherited from class org.immutables.criteria.repository.AbstractReader

groupBy, orderBy

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.immutables.criteria.repository.reactive.ReactiveFetcher

of

Constructor Detail

ReactiveReader

public ReactiveReader(Query query,
                      Backend.Session session)

Method Detail

newReader

protected ReactiveReader<T> newReader(Query query)

select

public <T1> ReactiveMapper1<T1> select(Projection<T1> proj1)

select

public <T1,T2> ReactiveMapper2<T1,T2> select(Projection<T1> proj1,
                                             Projection<T2> proj2)

select

public <T1,T2,T3> ReactiveMapper3<T1,T2,T3> select(Projection<T1> proj1,
                                                   Projection<T2> proj2,
                                                   Projection<T3> proj3)

select

public <T1,T2,T3,T4> ReactiveMapper4<T1,T2,T3,T4> select(Projection<T1> proj1,
                                                         Projection<T2> proj2,
                                                         Projection<T3> proj3,
                                                         Projection<T4> proj4)

select

public <T1,T2,T3,T4,T5> ReactiveMapper5<T1,T2,T3,T4,T5> select(Projection<T1> proj1,
                                                               Projection<T2> proj2,
                                                               Projection<T3> proj3,
                                                               Projection<T4> proj4,
                                                               Projection<T5> proj5)

select

public ReactiveMapperTuple select(Iterable<Projection<?>> projections)

fetch

public org.reactivestreams.Publisher<T> fetch()

one

public org.reactivestreams.Publisher<T> one()

oneOrNone

public org.reactivestreams.Publisher<T> oneOrNone()

exists

public org.reactivestreams.Publisher<Boolean> exists()

count

public org.reactivestreams.Publisher<Long> count()

map

public <X> ReactiveFetcher<X> map(Function<? super T,? extends X> mapFn)

changeQuery

public ReactiveFetcher<T> changeQuery(UnaryOperator<Query> mapFn)